akka.dispatch
Class ThreadPoolConfig$

java.lang.Object
  extended by akka.dispatch.ThreadPoolConfig$
All Implemented Interfaces:
java.io.Serializable

public class ThreadPoolConfig$
extends java.lang.Object
implements scala.Serializable

See Also:
Serialized Form

Field Summary
static ThreadPoolConfig$ MODULE$
          Static reference to the singleton instance of this Scala object.
 
Constructor Summary
ThreadPoolConfig$()
           
 
Method Summary
 scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> arrayBlockingQueue(int capacity, boolean fair)
           
 boolean defaultAllowCoreThreadTimeout()
           
 int defaultCorePoolSize()
           
 int defaultMaxPoolSize()
           
 java.util.concurrent.RejectedExecutionHandler defaultRejectionPolicy()
           
 scala.concurrent.duration.Duration defaultTimeout()
           
 scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue()
           
 scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue(int capacity)
           
 scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue)
           
 scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory)
           
 int scaledPoolSize(int floor, double multiplier, int ceiling)
           
 scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> synchronousQueue(boolean fair)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

MODULE$

public static final ThreadPoolConfig$ MODULE$
Static reference to the singleton instance of this Scala object.

Constructor Detail

ThreadPoolConfig$

public ThreadPoolConfig$()
Method Detail

defaultAllowCoreThreadTimeout

public boolean defaultAllowCoreThreadTimeout()

defaultCorePoolSize

public int defaultCorePoolSize()

defaultMaxPoolSize

public int defaultMaxPoolSize()

defaultTimeout

public scala.concurrent.duration.Duration defaultTimeout()

defaultRejectionPolicy

public java.util.concurrent.RejectedExecutionHandler defaultRejectionPolicy()

scaledPoolSize

public int scaledPoolSize(int floor,
                          double multiplier,
                          int ceiling)

arrayBlockingQueue

public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> arrayBlockingQueue(int capacity,
                                                                                                  boolean fair)

synchronousQueue

public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> synchronousQueue(boolean fair)

linkedBlockingQueue

public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue()

linkedBlockingQueue

public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue(int capacity)

reusableQueue

public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue)

reusableQueue

public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory)