[Batchserver-cvs] batchserver/src/org/jmonks/batchserver/framework/controller/pool CollectionJobPool.java,1.3,1.4

[Suresh <sur...@us...>]

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)