akka.dispatch
Class ThreadPoolConfig$
java.lang.Object
akka.dispatch.ThreadPoolConfig$
- All Implemented Interfaces:
- java.io.Serializable
public class ThreadPoolConfig$
- extends java.lang.Object
- implements scala.Serializable
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MODULE$
public static final ThreadPoolConfig$ MODULE$
- Static reference to the singleton instance of this Scala object.
ThreadPoolConfig$
public ThreadPoolConfig$()
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)