Update of /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool
In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv29009
Modified Files:
CollectionJobPool.java
Log Message:
no message
Index: CollectionJobPool.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/src/org/jmonks/batchserver/framework/controller/pool/CollectionJobPool.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -C2 -d -r1.3 -r1.4
*** CollectionJobPool.java 14 May 2006 01:31:32 -0000 1.3
--- CollectionJobPool.java 14 May 2006 04:36:44 -0000 1.4
***************
*** 49,52 ****
--- 49,56 ----
*/
protected int processedJobsCount=0;
+ /**
+ * Object to be pushed to the bounded buffer to denote the end of the pool.
+ */
+ private static final Object END_OF_POOL = new Object();
private static Logger logger=Logger.getLogger(CollectionJobPool.class);
***************
*** 66,69 ****
--- 70,75 ----
try
{
+ if(jobData==null)
+ jobData=END_OF_POOL;
this.pool.put(jobData);
loaded=true;
***************
*** 84,88 ****
{
jobData=this.pool.take();
! this.processedJobsCount++;
}
catch(InterruptedException exception)
--- 90,100 ----
{
jobData=this.pool.take();
! if(jobData==END_OF_POOL)
! {
! this.pool.put(END_OF_POOL);
! jobData=null;
! }
! else
! this.processedJobsCount++;
}
catch(InterruptedException exception)
|
