com.metamatrix.common.queue
Interface WorkerPool

All Superinterfaces:

java.util.concurrent.Executor

public interface WorkerPool
extends java.util.concurrent.Executor

Method Summary

boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
WorkerPoolStats	getStats()
boolean	hasWork()
boolean	isTerminated()
java.util.concurrent.ScheduledFuture<?>	schedule(java.lang.Runnable command, long delay, java.util.concurrent.TimeUnit unit)
java.util.concurrent.ScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
void	shutdown()
java.util.List<java.lang.Runnable>	shutdownNow()

Methods inherited from interface java.util.concurrent.Executor

execute

Method Detail

shutdown

void shutdown()

shutdownNow

java.util.List<java.lang.Runnable> shutdownNow()

awaitTermination

boolean awaitTermination(long timeout,
                         java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

isTerminated

boolean isTerminated()

getStats

WorkerPoolStats getStats()

hasWork

boolean hasWork()

schedule

java.util.concurrent.ScheduledFuture<?> schedule(java.lang.Runnable command,
                                                 long delay,
                                                 java.util.concurrent.TimeUnit unit)

scheduleAtFixedRate

java.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable command,
                                                            long initialDelay,
                                                            long period,
                                                            java.util.concurrent.TimeUnit unit)