abstract class OffloadThreadPoolFactory extends AnyRef
Experimental factory for generating the ExecutorService
used to offload work from the
Netty threads.
This is available so custom pools can be created, potentially with more interesting behavior and/or telemetry.
- Alphabetic
- By Inheritance
- OffloadThreadPoolFactory
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new OffloadThreadPoolFactory()
Abstract Value Members
- abstract def newPool(poolSize: Int, maxQueueLen: Int, stats: StatsReceiver): ExecutorService
Construct a new
ExecutorService
Construct a new
ExecutorService
- poolSize
The size of the pool as configured by the finagle flags
com.twitter.finagle.offload.numWorkers
andcom.twitter.finagle.offload.auto
- maxQueueLen
The maximum length of the queue in the pool as configured by the finagle flag
com.twitter.finagle.offload.maxQueueLen
- stats
StatsReceiver
to use for observability.
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()