org.apache.axis.components.threadpool
Class ThreadPool
java.lang.Object
org.apache.axis.components.threadpool.ThreadPool
public class ThreadPool
extends java.lang.Object
- James M Snell (jasnell@us.ibm.com)
void | addWorker(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(Runnable worker, boolean restart) - Used by MessageWorkers to notify the pool that it is done
|
DEFAULT_MAX_THREADS
public static final int DEFAULT_MAX_THREADS
_shutdown
public boolean _shutdown
log
protected static Log log
threadcount
protected long threadcount
threads
protected Map threads
ThreadPool
public ThreadPool()
ThreadPool
public ThreadPool(int maxPoolSize)
addWorker
public void addWorker(Runnable worker)
Adds a new worker to the pool
awaitShutdown
public void awaitShutdown()
throws InterruptedException
Await shutdown of the worker
awaitShutdown
public boolean awaitShutdown(long timeout)
throws InterruptedException
Await shutdown of the worker
cleanup
public void cleanup()
throws InterruptedException
getWorkerCount
public long getWorkerCount()
Returns the total number of currently active workers
interruptAll
public void interruptAll()
Forcefully interrupt all workers
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
safeShutdown
public void safeShutdown()
Forcefully shutdown the pool
shutdown
public void shutdown()
Forcefully shutdown the pool
workerDone
public void workerDone(Runnable worker,
boolean restart)
Used by MessageWorkers to notify the pool that it is done
Copyright © 2005 Apache Web Services Project. All Rights Reserved.