Packages

c

akka.dispatch

ThreadPoolConfigBuilder

final case class ThreadPoolConfigBuilder(config: ThreadPoolConfig) extends Product with Serializable

A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutor

Source
ThreadPoolBuilder.scala
Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ThreadPoolConfigBuilder
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ThreadPoolConfigBuilder(config: ThreadPoolConfig)

Value Members

  1. val config: ThreadPoolConfig
  2. def configure(fs: Option[Function[ThreadPoolConfigBuilder, ThreadPoolConfigBuilder]]*): ThreadPoolConfigBuilder
  3. def setAllowCoreThreadTimeout(allow: Boolean): ThreadPoolConfigBuilder
  4. def setCorePoolSize(size: Int): ThreadPoolConfigBuilder
  5. def setCorePoolSizeFromFactor(min: Int, multiplier: Double, max: Int): ThreadPoolConfigBuilder
  6. def setFixedPoolSize(size: Int): ThreadPoolConfigBuilder
  7. def setKeepAliveTime(time: Duration): ThreadPoolConfigBuilder
  8. def setKeepAliveTimeInMillis(time: Long): ThreadPoolConfigBuilder
  9. def setMaxPoolSize(size: Int): ThreadPoolConfigBuilder
  10. def setMaxPoolSizeFromFactor(min: Int, multiplier: Double, max: Int): ThreadPoolConfigBuilder
  11. def setQueueFactory(newQueueFactory: QueueFactory): ThreadPoolConfigBuilder
  12. def withNewThreadPoolWithArrayBlockingQueueWithCapacityAndFairness(capacity: Int, fair: Boolean): ThreadPoolConfigBuilder
  13. def withNewThreadPoolWithCustomBlockingQueue(queue: BlockingQueue[Runnable]): ThreadPoolConfigBuilder
  14. def withNewThreadPoolWithCustomBlockingQueue(newQueueFactory: QueueFactory): ThreadPoolConfigBuilder
  15. def withNewThreadPoolWithLinkedBlockingQueueWithCapacity(capacity: Int): ThreadPoolConfigBuilder
  16. def withNewThreadPoolWithLinkedBlockingQueueWithUnboundedCapacity: ThreadPoolConfigBuilder
  17. def withNewThreadPoolWithSynchronousQueueWithFairness(fair: Boolean): ThreadPoolConfigBuilder