com.onionnetworks.antflow.job
Class ExecutorFactoryImpl

java.lang.Object
  com.onionnetworks.antflow.job.ExecutorFactoryImpl

All Implemented Interfaces:

ExecutorFactory

public class ExecutorFactoryImpl

extends java.lang.Object

implements ExecutorFactory

Used to store the per-Task executors. Also provides status dumps.

Nested Class Summary

class

ExecutorFactoryImpl.CountableLinkedQueue necessary because channels are lame

Field Summary

static int

POOL_SIZE

Constructor Summary

ExecutorFactoryImpl()

Method Summary

protected EDU.oswego.cs.dl.util.concurrent.Executor	createExecutor(java.lang.String key, int size)
void	dumpState()
EDU.oswego.cs.dl.util.concurrent.Executor	getExecutor(java.lang.String key, int size) Gets executor for a key -- creates if necessary

Methods inherited from class java.lang.Object

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

Field Detail

POOL_SIZE

public static final int POOL_SIZE

See Also:

Constant Field Values

Constructor Detail

ExecutorFactoryImpl

public ExecutorFactoryImpl()

Method Detail

getExecutor

public EDU.oswego.cs.dl.util.concurrent.Executor getExecutor(java.lang.String key,
                                                             int size)

Gets executor for a key -- creates if necessary

Specified by:

getExecutor in interface ExecutorFactory

Parameters:

key - for looking up pre-existing pools if caching is done

size - number of threads in the executor if pooling. Ignored if a new Executor isn't created

createExecutor

protected EDU.oswego.cs.dl.util.concurrent.Executor createExecutor(java.lang.String key,
                                                                   int size)

dumpState

public void dumpState()

Specified by:

dumpState in interface ExecutorFactory