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