akka.dispatch

Class ThreadPoolConfig

java.lang.Object

akka.dispatch.ThreadPoolConfig

All Implemented Interfaces:

ExecutorServiceFactoryProvider, java.io.Serializable, scala.Equals, scala.Product

public final class ThreadPoolConfig
extends java.lang.Object
implements ExecutorServiceFactoryProvider, scala.Product, scala.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ThreadPoolConfig.ThreadPoolExecutorServiceFactory

Constructor Summary

Constructors

Constructor and Description
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

Modifier and Type	Method and Description
boolean	allowCorePoolTimeout()
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>	arrayBlockingQueue(int capacity, boolean fair)
abstract static boolean	canEqual(java.lang.Object that)
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()
abstract static boolean	equals(java.lang.Object that)
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()
abstract static int	productArity()
abstract static java.lang.Object	productElement(int n)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
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

$init$, 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)

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<java.lang.Object> productIterator()

productPrefix

public static java.lang.String productPrefix()

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