Package akka.dispatch

Class ThreadPoolConfig

    • Constructor Summary

      Constructors 
      Constructor Description
      ThreadPoolConfig​(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)  
    • Constructor Detail

      • ThreadPoolConfig

        public ThreadPoolConfig​(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)
    • Method Detail

      • $lessinit$greater$default$1

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

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

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

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

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

        public static java.util.concurrent.RejectedExecutionHandler $lessinit$greater$default$6()
      • defaultAllowCoreThreadTimeout

        public static boolean defaultAllowCoreThreadTimeout()
      • defaultCorePoolSize

        public static int defaultCorePoolSize()
      • defaultMaxPoolSize

        public static int defaultMaxPoolSize()
      • defaultTimeout

        public static scala.concurrent.duration.Duration defaultTimeout()
      • defaultRejectionPolicy

        public static java.util.concurrent.RejectedExecutionHandler defaultRejectionPolicy()
      • scaledPoolSize

        public static int scaledPoolSize​(int floor,
                                         double multiplier,
                                         int ceiling)
      • arrayBlockingQueue

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

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

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

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

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

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

        public static 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
      • apply$default$1

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

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

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

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

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

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

        public static 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)
      • allowCorePoolTimeout

        public boolean allowCorePoolTimeout()
      • corePoolSize

        public int corePoolSize()
      • maxPoolSize

        public int maxPoolSize()
      • threadTimeout

        public scala.concurrent.duration.Duration threadTimeout()
      • queueFactory

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

        public java.util.concurrent.RejectedExecutionHandler rejectionPolicy()
      • copy

        public ThreadPoolConfig copy​(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)
      • copy$default$1

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

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

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

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

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

        public java.util.concurrent.RejectedExecutionHandler copy$default$6()
      • productPrefix

        public java.lang.String productPrefix()
        Specified by:
        productPrefix in interface scala.Product
      • productArity

        public int productArity()
        Specified by:
        productArity in interface scala.Product
      • productElement

        public java.lang.Object productElement​(int x$1)
        Specified by:
        productElement in interface scala.Product
      • productIterator

        public scala.collection.Iterator<java.lang.Object> productIterator()
        Specified by:
        productIterator in interface scala.Product
      • canEqual

        public boolean canEqual​(java.lang.Object x$1)
        Specified by:
        canEqual in interface scala.Equals
      • productElementName

        public java.lang.String productElementName​(int x$1)
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object x$1)
        Specified by:
        equals in interface scala.Equals
        Overrides:
        equals in class java.lang.Object