com.twitter.finagle.netty4.param
TrackWorkerPoolExecutionDelay
Companion object TrackWorkerPoolExecutionDelay
case class TrackWorkerPoolExecutionDelay(enableTracking: Boolean, trackingTaskPeriod: Duration, threadDumpThreshold: Duration) extends Product with Serializable
Control for tracking execution delay in the worker threads for a listener. This is intended to be enabled for perf tracking, and may impact performance as it adds tracking runnables to the event executors. Stats will be written to the stats receiver for the listener under workerpool/deviation_ms. When thread dumping is enabled, all logging is done at the warning level.
- enableTracking
If true enable thread pause tracking.
- trackingTaskPeriod
The fixed time scheduling window for the execution delay runnable.
- threadDumpThreshold
If > 0ms, enable stack dumping of threads when they have been delayed for more than the threshold. Thresholds of < 10ms will not work as expected as the underlying executors do not use high resolution timers.
- Alphabetic
- By Inheritance
- TrackWorkerPoolExecutionDelay
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new TrackWorkerPoolExecutionDelay(enableTracking: Boolean, trackingTaskPeriod: Duration, threadDumpThreshold: Duration)
- enableTracking
If true enable thread pause tracking.
- trackingTaskPeriod
The fixed time scheduling window for the execution delay runnable.
- threadDumpThreshold
If > 0ms, enable stack dumping of threads when they have been delayed for more than the threshold. Thresholds of < 10ms will not work as expected as the underlying executors do not use high resolution timers.
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()
- val enableTracking: Boolean
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- 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()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def mk(): (TrackWorkerPoolExecutionDelay, Param[TrackWorkerPoolExecutionDelay])
- 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()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val threadDumpThreshold: Duration
- val trackingTaskPeriod: Duration
- 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()