[Babeldoc-devel] babeldoc/modules/core/src/com/babeldoc/core/pipeline/processor ThreadPooledPipelineStageProcessor.java,1.1,1.2

[<tr...@us...>]

Update of /cvsroot/babeldoc/babeldoc/modules/core/src/com/babeldoc/core/pipeline/processor
In directory sc8-pr-cvs1:/tmp/cvs-serv16126/src/com/babeldoc/core/pipeline/processor

Modified Files:
	ThreadPooledPipelineStageProcessor.java 
Log Message:
Removed the jakarta commons threadpool code - now uses the oswego concurrent classes.

Index: ThreadPooledPipelineStageProcessor.java
===================================================================
RCS file: /cvsroot/babeldoc/babeldoc/modules/core/src/com/babeldoc/core/pipeline/processor/ThreadPooledPipelineStageProcessor.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** ThreadPooledPipelineStageProcessor.java	16 Jul 2003 22:45:28 -0000	1.1
--- ThreadPooledPipelineStageProcessor.java	4 Aug 2003 23:46:38 -0000	1.2
***************
*** 72,77 ****
  
  import org.apache.commons.lang.NumberUtils;
! import org.apache.commons.threadpool.ThreadPool;
! import org.apache.commons.threadpool.DefaultThreadPool;
  
  /**
--- 72,77 ----
  
  import org.apache.commons.lang.NumberUtils;
! import EDU.oswego.cs.dl.util.concurrent.Executor;
! import EDU.oswego.cs.dl.util.concurrent.PooledExecutor;
  
  /**
***************
*** 86,90 ****
  
    private int poolsize;
!   private ThreadPool threadPool;
  
    /**
--- 86,90 ----
  
    private int poolsize;
!   private Executor threadPool;
  
    /**
***************
*** 99,103 ****
      poolsize = NumberUtils.stringToInt((String)config.get(POOL_SIZE), DEFAULT_POOLSIZE);
  //    System.out.println("Setting up a pool with size of: "+poolsize);
!     threadPool = new DefaultThreadPool(poolsize);
    }
  
--- 99,103 ----
      poolsize = NumberUtils.stringToInt((String)config.get(POOL_SIZE), DEFAULT_POOLSIZE);
  //    System.out.println("Setting up a pool with size of: "+poolsize);
!     threadPool = new PooledExecutor(poolsize);
    }
  
***************
*** 120,132 ****
      for (int j = 0; j < numResults; j++) {
        final PipelineStageResult psresult = psResults[j];
!       threadPool.invokeLater(new Runnable() {
!         public void run() {
!           try {
!             processPipelineStageResult(psresult, syncResults);
!           } catch (PipelineException e) {
!             LogService.getInstance().logError(e);
            }
!         }
!       });
      }
    }
--- 120,136 ----
      for (int j = 0; j < numResults; j++) {
        final PipelineStageResult psresult = psResults[j];
!       try {
!         threadPool.execute(new Runnable() {
!           public void run() {
!             try {
!               processPipelineStageResult(psresult, syncResults);
!             } catch (PipelineException e) {
!               LogService.getInstance().logError(e);
!             }
            }
!         });
!       } catch (InterruptedException e) {
!         throw new PipelineException("", e);
!       }
      }
    }