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, Product, Equals, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ThreadPoolConfigBuilder
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ThreadPoolConfigBuilder(config: ThreadPoolConfig)

Value Members

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