Field Detail

• log

  protected static org.apache.commons.logging.Log log

• DEFAULT_MAX_THREADS

  public static final int DEFAULT_MAX_THREADS

  See Also:

  Constant Field Values

• threads

  protected Map threads

• threadcount

  protected long threadcount

• _shutdown

  public boolean _shutdown

Constructor Detail

• ThreadPool

  public ThreadPool()

• ThreadPool

  public ThreadPool(int maxPoolSize)

Method Detail

• cleanup

  public void cleanup()
               throws InterruptedException

  Throws:

  InterruptedException

• isShutdown

  public boolean isShutdown()

  Returns true if all workers have been shutdown

• isShuttingDown

  public boolean isShuttingDown()

  Returns true if all workers are in the process of shutting down

• getWorkerCount

  public long getWorkerCount()

  Returns the total number of currently active workers

• addWorker

  public void addWorker(Runnable worker)

  Adds a new worker to the pool

• interruptAll

  public void interruptAll()

  Forcefully interrupt all workers

• shutdown

  public void shutdown()

  Forcefully shutdown the pool

• safeShutdown

  public void safeShutdown()

  Forcefully shutdown the pool

• awaitShutdown

  public void awaitShutdown()
                     throws InterruptedException

  Await shutdown of the worker

  Throws:

  InterruptedException

• awaitShutdown

  public boolean awaitShutdown(long timeout)
                        throws InterruptedException

  Await shutdown of the worker

  Throws:

  InterruptedException

• workerDone

  public void workerDone(Runnable worker,
                boolean restart)

  Used by MessageWorkers to notify the pool that it is done