org.apache.axis.components.threadpool

Class ThreadPool


public class ThreadPool
extends java.lang.Object

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

Field Summary

static int
DEFAULT_MAX_THREADS
boolean
_shutdown
protected static Log
log
protected long
threadcount
protected Map
threads

Constructor Summary

ThreadPool()
ThreadPool(int maxPoolSize)

Method Summary

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

Field Details

DEFAULT_MAX_THREADS

public static final int DEFAULT_MAX_THREADS

Field Value:
100


_shutdown

public boolean _shutdown


log

protected static Log log


threadcount

protected long threadcount


threads

protected Map threads

Constructor Details

ThreadPool

public ThreadPool()


ThreadPool

public ThreadPool(int maxPoolSize)

Method Details

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 B) 2005 Apache Web Services Project. All Rights Reserved.