final case class ThreadPoolConfig(allowCorePoolTimeout: Boolean = ..., corePoolSize: Int = ..., maxPoolSize: Int = ThreadPoolConfig.defaultMaxPoolSize, threadTimeout: Duration = ThreadPoolConfig.defaultTimeout, queueFactory: QueueFactory = ..., rejectionPolicy: RejectedExecutionHandler = ...) extends ExecutorServiceFactoryProvider with Product with Serializable
A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcher
- Source
- ThreadPoolBuilder.scala
Linear Supertypes
Type Hierarchy
Ordering
- Alphabetic
- By Inheritance
Inherited
- ThreadPoolConfig
- Serializable
- Serializable
- Product
- Equals
- ExecutorServiceFactoryProvider
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new ThreadPoolConfig(allowCorePoolTimeout: Boolean = ..., corePoolSize: Int = ..., maxPoolSize: Int = ThreadPoolConfig.defaultMaxPoolSize, threadTimeout: Duration = ThreadPoolConfig.defaultTimeout, queueFactory: QueueFactory = ..., rejectionPolicy: RejectedExecutionHandler = ...)
Type Members
- class ThreadPoolExecutorServiceFactory extends ExecutorServiceFactory
Value Members
- val allowCorePoolTimeout: Boolean
- val corePoolSize: Int
-
final
def
createExecutorServiceFactory(id: String, threadFactory: ThreadFactory): ExecutorServiceFactory
- Definition Classes
- ThreadPoolConfig → ExecutorServiceFactoryProvider
- val maxPoolSize: Int
- val queueFactory: QueueFactory
- val rejectionPolicy: RejectedExecutionHandler
- val threadTimeout: Duration