Package akka.dispatch

Class ThreadPoolConfig$

  • All Implemented Interfaces:
    java.io.Serializable, scala.Serializable

    public class ThreadPoolConfig$
    extends java.lang.Object
    implements scala.Serializable
    See Also:
    Serialized Form
    • Field Summary

      Fields 
      Modifier and Type Field Description
      static ThreadPoolConfig$ MODULE$
      Static reference to the singleton instance of this Scala object.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean $lessinit$greater$default$1()
      A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcher
      int $lessinit$greater$default$2()  
      int $lessinit$greater$default$3()  
      scala.concurrent.duration.Duration $lessinit$greater$default$4()  
      scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> $lessinit$greater$default$5()  
      java.util.concurrent.RejectedExecutionHandler $lessinit$greater$default$6()  
      ThreadPoolConfig apply​(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)
      A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcher
      boolean apply$default$1()  
      int apply$default$2()  
      int apply$default$3()  
      scala.concurrent.duration.Duration apply$default$4()  
      scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> apply$default$5()  
      java.util.concurrent.RejectedExecutionHandler apply$default$6()  
      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)  
      scala.Option<scala.Tuple6<java.lang.Object,​java.lang.Object,​java.lang.Object,​scala.concurrent.duration.Duration,​scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>,​java.util.concurrent.RejectedExecutionHandler>> unapply​(ThreadPoolConfig x$0)  
      • 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

      • $lessinit$greater$default$1

        public boolean $lessinit$greater$default$1()
        A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcher
        Returns:
        (undocumented)
      • $lessinit$greater$default$2

        public int $lessinit$greater$default$2()
      • $lessinit$greater$default$3

        public int $lessinit$greater$default$3()
      • $lessinit$greater$default$4

        public scala.concurrent.duration.Duration $lessinit$greater$default$4()
      • $lessinit$greater$default$5

        public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> $lessinit$greater$default$5()
      • $lessinit$greater$default$6

        public java.util.concurrent.RejectedExecutionHandler $lessinit$greater$default$6()
      • 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)
      • apply

        public ThreadPoolConfig apply​(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)
        A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcher
        Parameters:
        allowCorePoolTimeout - (undocumented)
        corePoolSize - (undocumented)
        maxPoolSize - (undocumented)
        threadTimeout - (undocumented)
        queueFactory - (undocumented)
        rejectionPolicy - (undocumented)
        Returns:
        (undocumented)
      • apply$default$1

        public boolean apply$default$1()
      • apply$default$2

        public int apply$default$2()
      • apply$default$3

        public int apply$default$3()
      • apply$default$4

        public scala.concurrent.duration.Duration apply$default$4()
      • apply$default$5

        public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> apply$default$5()
      • apply$default$6

        public java.util.concurrent.RejectedExecutionHandler apply$default$6()
      • unapply

        public scala.Option<scala.Tuple6<java.lang.Object,​java.lang.Object,​java.lang.Object,​scala.concurrent.duration.Duration,​scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>,​java.util.concurrent.RejectedExecutionHandler>> unapply​(ThreadPoolConfig x$0)