ds.funnel.node.task

Class SuperThreadPool

java.lang.Object

ds.funnel.node.task.SuperThreadPool

public class SuperThreadPool
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SuperThreadPool.SubmittedRunnable

Constructor Summary

Constructors

Constructor and Description
SuperThreadPool(int inNumThreads)

Method Summary

Modifier and Type	Method and Description
boolean	awaitShutdown(long inMillis)
int	getNumThreads()
java.util.List<SuperThreadPool.SubmittedRunnable>	getQueue()
int	getQueueSize()
void	setNumThreads(int inNumThreads)
void	shutdown(long inGracefulMillis)
SuperThreadPool.SubmittedRunnable	submit(java.lang.Runnable inRunnable)
SuperThreadPool.SubmittedRunnable	submitLater(java.lang.Runnable inRunnable, long inDeferMillis)
SuperThreadPool.SubmittedRunnable	submitPeriodic(java.lang.Runnable inRunnable, long inDeferMillis, long inPeriodMillis)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SuperThreadPool

public SuperThreadPool(int inNumThreads)

Method Detail

submit

public SuperThreadPool.SubmittedRunnable submit(java.lang.Runnable inRunnable)

submitLater

public SuperThreadPool.SubmittedRunnable submitLater(java.lang.Runnable inRunnable,
                                                     long inDeferMillis)

submitPeriodic

public SuperThreadPool.SubmittedRunnable submitPeriodic(java.lang.Runnable inRunnable,
                                                        long inDeferMillis,
                                                        long inPeriodMillis)

shutdown

public void shutdown(long inGracefulMillis)

awaitShutdown

public boolean awaitShutdown(long inMillis)
                      throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getNumThreads

public int getNumThreads()

setNumThreads

public void setNumThreads(int inNumThreads)

getQueue

public java.util.List<SuperThreadPool.SubmittedRunnable> getQueue()

getQueueSize

public int getQueueSize()