akka.dispatch
Class ThreadPoolConfigBuilder

java.lang.Object
  extended by akka.dispatch.ThreadPoolConfigBuilder
All Implemented Interfaces:
java.io.Serializable, scala.Equals, scala.Product

public 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
ThreadPoolConfigBuilder(ThreadPoolConfig config)
           
 
Method Summary
 ThreadPoolConfig config()
           
 ThreadPoolConfigBuilder configure(scala.collection.Seq<scala.Option<scala.Function1<ThreadPoolConfigBuilder,ThreadPoolConfigBuilder>>> fs)
           
 ThreadPoolConfigBuilder setAllowCoreThreadTimeout(boolean allow)
           
 ThreadPoolConfigBuilder setCorePoolSize(int size)
           
 ThreadPoolConfigBuilder setCorePoolSizeFromFactor(int min, double multiplier, int max)
           
 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
productArity, productElement, productIterator, productPrefix
 
Methods inherited from interface scala.Equals
canEqual, equals
 

Constructor Detail

ThreadPoolConfigBuilder

public ThreadPoolConfigBuilder(ThreadPoolConfig config)
Method Detail

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)

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)