akka.dispatch

Class ThreadPoolConfigBuilder

java.lang.Object

akka.dispatch.ThreadPoolConfigBuilder

All Implemented Interfaces:

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

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

A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutor

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ThreadPoolConfigBuilder(ThreadPoolConfig config)

Method Summary

Modifier and Type	Method and Description
abstract static boolean	canEqual(java.lang.Object that)
ThreadPoolConfig	config()
ThreadPoolConfigBuilder	configure(scala.collection.Seq<scala.Option<scala.Function1<ThreadPoolConfigBuilder,ThreadPoolConfigBuilder>>> fs)
abstract static boolean	equals(java.lang.Object that)
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()
ThreadPoolConfigBuilder	setAllowCoreThreadTimeout(boolean allow)
ThreadPoolConfigBuilder	setCorePoolSize(int size)
ThreadPoolConfigBuilder	setCorePoolSizeFromFactor(int min, double multiplier, int max)
ThreadPoolConfigBuilder	setFixedPoolSize(int size)
ThreadPoolConfigBuilder	setKeepAliveTime(scala.concurrent.duration.Duration time)
ThreadPoolConfigBuilder	setKeepAliveTimeInMillis(long time)
ThreadPoolConfigBuilder	setMaxPoolSize(int size)
ThreadPoolConfigBuilder	setMaxPoolSizeFromFactor(int min, double multiplier, int max)
ThreadPoolConfigBuilder	setQueueFactory(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> newQueueFactory)
ThreadPoolConfigBuilder	withNewThreadPoolWithArrayBlockingQueueWithCapacityAndFairness(int capacity, boolean fair)
ThreadPoolConfigBuilder	withNewThreadPoolWithCustomBlockingQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue)
ThreadPoolConfigBuilder	withNewThreadPoolWithCustomBlockingQueue(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> newQueueFactory)
ThreadPoolConfigBuilder	withNewThreadPoolWithLinkedBlockingQueueWithCapacity(int capacity)
ThreadPoolConfigBuilder	withNewThreadPoolWithLinkedBlockingQueueWithUnboundedCapacity()
ThreadPoolConfigBuilder	withNewThreadPoolWithSynchronousQueueWithFairness(boolean fair)

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

ThreadPoolConfigBuilder

public ThreadPoolConfigBuilder(ThreadPoolConfig config)

Method Detail

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()

config

public ThreadPoolConfig config()

withNewThreadPoolWithCustomBlockingQueue

public ThreadPoolConfigBuilder withNewThreadPoolWithCustomBlockingQueue(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> newQueueFactory)

withNewThreadPoolWithCustomBlockingQueue

public ThreadPoolConfigBuilder withNewThreadPoolWithCustomBlockingQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue)

withNewThreadPoolWithLinkedBlockingQueueWithUnboundedCapacity

public ThreadPoolConfigBuilder withNewThreadPoolWithLinkedBlockingQueueWithUnboundedCapacity()

withNewThreadPoolWithLinkedBlockingQueueWithCapacity

public ThreadPoolConfigBuilder withNewThreadPoolWithLinkedBlockingQueueWithCapacity(int capacity)

withNewThreadPoolWithSynchronousQueueWithFairness

public ThreadPoolConfigBuilder withNewThreadPoolWithSynchronousQueueWithFairness(boolean fair)

withNewThreadPoolWithArrayBlockingQueueWithCapacityAndFairness

public ThreadPoolConfigBuilder withNewThreadPoolWithArrayBlockingQueueWithCapacityAndFairness(int capacity,
                                                                                              boolean fair)

setFixedPoolSize

public ThreadPoolConfigBuilder setFixedPoolSize(int size)

setCorePoolSize

public ThreadPoolConfigBuilder setCorePoolSize(int size)

setMaxPoolSize

public ThreadPoolConfigBuilder setMaxPoolSize(int size)

setCorePoolSizeFromFactor

public ThreadPoolConfigBuilder setCorePoolSizeFromFactor(int min,
                                                         double multiplier,
                                                         int max)

setMaxPoolSizeFromFactor

public ThreadPoolConfigBuilder setMaxPoolSizeFromFactor(int min,
                                                        double multiplier,
                                                        int max)

setKeepAliveTimeInMillis

public ThreadPoolConfigBuilder setKeepAliveTimeInMillis(long time)

setKeepAliveTime

public ThreadPoolConfigBuilder setKeepAliveTime(scala.concurrent.duration.Duration time)

setAllowCoreThreadTimeout

public ThreadPoolConfigBuilder setAllowCoreThreadTimeout(boolean allow)

setQueueFactory

public ThreadPoolConfigBuilder setQueueFactory(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> newQueueFactory)

configure

public ThreadPoolConfigBuilder configure(scala.collection.Seq<scala.Option<scala.Function1<ThreadPoolConfigBuilder,ThreadPoolConfigBuilder>>> fs)