akka.dispatch
Class ThreadPoolConfig
java.lang.Object
akka.dispatch.ThreadPoolConfig
- All Implemented Interfaces:
- ExecutorServiceFactoryProvider, java.io.Serializable, scala.Equals, scala.Product
public class ThreadPoolConfig
- extends java.lang.Object
- implements ExecutorServiceFactoryProvider, scala.Product, scala.Serializable
- See Also:
- Serialized Form
Constructor Summary |
ThreadPoolConfig(boolean allowCorePoolTimeout,
int corePoolSize,
int maxPoolSize,
scala.concurrent.duration.Duration threadTimeout,
scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory,
java.util.concurrent.RejectedExecutionHandler rejectionPolicy)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface scala.Product |
productArity, productElement, productIterator, productPrefix |
Methods inherited from interface scala.Equals |
canEqual, equals |
ThreadPoolConfig
public ThreadPoolConfig(boolean allowCorePoolTimeout,
int corePoolSize,
int maxPoolSize,
scala.concurrent.duration.Duration threadTimeout,
scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory,
java.util.concurrent.RejectedExecutionHandler rejectionPolicy)
defaultAllowCoreThreadTimeout
public static boolean defaultAllowCoreThreadTimeout()
defaultCorePoolSize
public static int defaultCorePoolSize()
defaultMaxPoolSize
public static int defaultMaxPoolSize()
defaultTimeout
public static scala.concurrent.duration.Duration defaultTimeout()
defaultRejectionPolicy
public static java.util.concurrent.RejectedExecutionHandler defaultRejectionPolicy()
scaledPoolSize
public static int scaledPoolSize(int floor,
double multiplier,
int ceiling)
arrayBlockingQueue
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> arrayBlockingQueue(int capacity,
boolean fair)
synchronousQueue
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> synchronousQueue(boolean fair)
linkedBlockingQueue
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue()
linkedBlockingQueue
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue(int capacity)
reusableQueue
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue)
reusableQueue
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory)
allowCorePoolTimeout
public boolean allowCorePoolTimeout()
corePoolSize
public int corePoolSize()
maxPoolSize
public int maxPoolSize()
threadTimeout
public scala.concurrent.duration.Duration threadTimeout()
queueFactory
public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory()
rejectionPolicy
public java.util.concurrent.RejectedExecutionHandler rejectionPolicy()
createExecutorServiceFactory
public final ExecutorServiceFactory createExecutorServiceFactory(java.lang.String id,
java.util.concurrent.ThreadFactory threadFactory)
- Specified by:
createExecutorServiceFactory
in interface ExecutorServiceFactoryProvider