akka.dispatch
Class ThreadPoolConfig

java.lang.Object
  extended by 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

Nested Class Summary
 class ThreadPoolConfig.ThreadPoolExecutorServiceFactory
           
 
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)
           
 
Method Summary
 boolean allowCorePoolTimeout()
           
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> arrayBlockingQueue(int capacity, boolean fair)
           
 int corePoolSize()
           
 ExecutorServiceFactory createExecutorServiceFactory(java.lang.String id, java.util.concurrent.ThreadFactory threadFactory)
           
static boolean defaultAllowCoreThreadTimeout()
           
static int defaultCorePoolSize()
           
static int defaultMaxPoolSize()
           
static java.util.concurrent.RejectedExecutionHandler defaultRejectionPolicy()
           
static scala.concurrent.duration.Duration defaultTimeout()
           
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue()
           
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue(int capacity)
           
 int maxPoolSize()
           
 scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory()
           
 java.util.concurrent.RejectedExecutionHandler rejectionPolicy()
           
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue)
           
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory)
           
static int scaledPoolSize(int floor, double multiplier, int ceiling)
           
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> synchronousQueue(boolean fair)
           
 scala.concurrent.duration.Duration threadTimeout()
           
 
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
 

Constructor Detail

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)
Method Detail

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