Update of /cvsroot/jboost/jboost/src/jboost/util
In directory fdv4jf1.ch3.sourceforge.com:/tmp/cvs-serv11232/src/jboost/util
Modified Files:
Tag: jboost-2_0
BaseCountWorker.java ExecutorSinglet.java
Log Message:
jboost 2.0
Index: BaseCountWorker.java
===================================================================
RCS file: /cvsroot/jboost/jboost/src/jboost/util/BaseCountWorker.java,v
retrieving revision 1.1.1.1
retrieving revision 1.1.1.1.4.1
diff -C2 -d -r1.1.1.1 -r1.1.1.1.4.1
*** BaseCountWorker.java 16 May 2007 04:06:02 -0000 1.1.1.1
--- BaseCountWorker.java 8 Jun 2009 23:40:49 -0000 1.1.1.1.4.1
***************
*** 1,5 ****
package jboost.util;
! import EDU.oswego.cs.dl.util.concurrent.CountDown;
/**
--- 1,5 ----
package jboost.util;
! import java.util.concurrent.CountDownLatch;
/**
***************
*** 10,16 ****
*/
public abstract class BaseCountWorker implements Runnable {
! CountDown count;
! public BaseCountWorker(CountDown count) {
this.count=count;
}
--- 10,16 ----
*/
public abstract class BaseCountWorker implements Runnable {
! CountDownLatch count;
! public BaseCountWorker(CountDownLatch count) {
this.count=count;
}
***************
*** 22,26 ****
doWork();
} finally {
! count.release();
}
--- 22,26 ----
doWork();
} finally {
! count.countDown();
}
Index: ExecutorSinglet.java
===================================================================
RCS file: /cvsroot/jboost/jboost/src/jboost/util/ExecutorSinglet.java,v
retrieving revision 1.1.1.1
retrieving revision 1.1.1.1.4.1
diff -C2 -d -r1.1.1.1 -r1.1.1.1.4.1
*** ExecutorSinglet.java 16 May 2007 04:06:02 -0000 1.1.1.1
--- ExecutorSinglet.java 8 Jun 2009 23:40:49 -0000 1.1.1.1.4.1
***************
*** 1,6 ****
package jboost.util;
! import EDU.oswego.cs.dl.util.concurrent.DirectExecutor;
! import EDU.oswego.cs.dl.util.concurrent.Executor;
/**
--- 1,7 ----
package jboost.util;
! import java.util.concurrent.Executor;
! import java.util.concurrent.Executors;
!
/**
***************
*** 10,14 ****
*/
public class ExecutorSinglet {
! static Executor e=new DirectExecutor();
public static Executor getExecutor() {
--- 11,16 ----
*/
public class ExecutorSinglet {
!
! static Executor e = Executors.newFixedThreadPool(1);
public static Executor getExecutor() {
***************
*** 19,21 ****
--- 21,24 ----
e=ex;
}
+
}
|