Package org.apache.pekko.dispatch
Class ThreadPoolConfig
- java.lang.Object
-
- org.apache.pekko.dispatch.ThreadPoolConfig
-
- All Implemented Interfaces:
java.io.Serializable
,ExecutorServiceFactoryProvider
,scala.Equals
,scala.Product
public final class ThreadPoolConfig extends java.lang.Object implements ExecutorServiceFactoryProvider, scala.Product, java.io.Serializable
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
ThreadPoolConfig.ThreadPoolExecutorServiceFactory
-
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)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static boolean
$lessinit$greater$default$1()
A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcherstatic int
$lessinit$greater$default$2()
static int
$lessinit$greater$default$3()
static scala.concurrent.duration.Duration
$lessinit$greater$default$4()
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
$lessinit$greater$default$5()
static java.util.concurrent.RejectedExecutionHandler
$lessinit$greater$default$6()
boolean
allowCorePoolTimeout()
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 Dispatcherstatic boolean
apply$default$1()
static int
apply$default$2()
static int
apply$default$3()
static scala.concurrent.duration.Duration
apply$default$4()
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
apply$default$5()
static java.util.concurrent.RejectedExecutionHandler
apply$default$6()
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
arrayBlockingQueue(int capacity, boolean fair)
boolean
canEqual(java.lang.Object x$1)
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)
boolean
copy$default$1()
int
copy$default$2()
int
copy$default$3()
scala.concurrent.duration.Duration
copy$default$4()
scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
copy$default$5()
java.util.concurrent.RejectedExecutionHandler
copy$default$6()
int
corePoolSize()
ExecutorServiceFactory
createExecutorServiceFactory(java.lang.String id, java.util.concurrent.ThreadFactory threadFactory)
static boolean
defaultAllowCoreThreadTimeout()
static int
defaultCorePoolSize()
static int
defaultMaxPoolSize()
static java.util.concurrent.RejectedExecutionHandler
defaultRejectionPolicy()
static scala.concurrent.duration.Duration
defaultTimeout()
boolean
equals(java.lang.Object x$1)
int
hashCode()
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
linkedBlockingQueue()
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
linkedBlockingQueue(int capacity)
int
maxPoolSize()
int
productArity()
java.lang.Object
productElement(int x$1)
java.lang.String
productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
queueFactory()
java.util.concurrent.RejectedExecutionHandler
rejectionPolicy()
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
reusableQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue)
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
reusableQueue(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory)
static int
scaledPoolSize(int floor, double multiplier, int ceiling)
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>>
synchronousQueue(boolean fair)
scala.concurrent.duration.Duration
threadTimeout()
java.lang.String
toString()
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)
-
-
-
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()
-
createExecutorServiceFactory
public ExecutorServiceFactory createExecutorServiceFactory(java.lang.String id, java.util.concurrent.ThreadFactory threadFactory)
- Specified by:
createExecutorServiceFactory
in interfaceExecutorServiceFactoryProvider
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementName
in interfacescala.Product
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-