org.apache.axis.components.threadpool
Class ThreadPool

java.lang.Object
  |
  +--org.apache.axis.components.threadpool.ThreadPool

public class ThreadPool
extends java.lang.Object

Author:
James M Snell (jasnell@us.ibm.com)

Field Summary
 boolean _shutdown
           
protected static org.apache.commons.logging.Log log
           
static long MAX_THREADS
           
protected  long threadcount
           
protected  java.util.Map threads
           
 
Constructor Summary
ThreadPool()
           
 
Method Summary
 void addWorker(java.lang.Runnable worker)
          Adds a new worker to the pool
 void awaitShutdown()
          Await shutdown of the worker
 boolean awaitShutdown(long timeout)
          Await shutdown of the worker
 void cleanup()
           
 long getWorkerCount()
          Returns the total number of currently active workers
 void interruptAll()
          Forcefully interrupt all workers
 boolean isShutdown()
          Returns true if all workers have been shutdown
 boolean isShuttingDown()
          Returns true if all workers are in the process of shutting down
 void safeShutdown()
          Forcefully shutdown the pool
 void shutdown()
          Forcefully shutdown the pool
 void workerDone(java.lang.Runnable worker, boolean restart)
          Used by MessageWorkers to notify the pool that it is done
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

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

MAX_THREADS

public static final long MAX_THREADS
See Also:
Constant Field Values

threads

protected java.util.Map threads

threadcount

protected long threadcount

_shutdown

public boolean _shutdown
Constructor Detail

ThreadPool

public ThreadPool()
Method Detail

cleanup

public void cleanup()
             throws java.lang.InterruptedException
java.lang.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(java.lang.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 java.lang.InterruptedException
Await shutdown of the worker

java.lang.InterruptedException

awaitShutdown

public boolean awaitShutdown(long timeout)
                      throws java.lang.InterruptedException
Await shutdown of the worker

java.lang.InterruptedException

workerDone

public void workerDone(java.lang.Runnable worker,
                       boolean restart)
Used by MessageWorkers to notify the pool that it is done



Copyright © 2003 Apache Web Services Project. All Rights Reserved.