object StarvationDetector
- Source
- StarvationDetector.scala
- Alphabetic
- By Inheritance
- StarvationDetector
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class UnsupportedDispatcherException(msg: String) extends RuntimeException with NoStackTrace with Product with Serializable
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 checkDispatcher(provider: ClassicActorSystemProvider, dispatcherConfigPath: String, config: StarvationDetectorSettings): Unit
Creates and runs a StarvationDetector thread for the given Akka dispatcher defined in config with the
dispatcherConfigPath.Creates and runs a StarvationDetector thread for the given Akka dispatcher defined in config with the
dispatcherConfigPath.Note that a dispatcher will only have one StarvationDetector for it active at a time. If there is another StarvationDetector running, this method does nothing.
- def checkDispatcher(provider: ClassicActorSystemProvider, dispatcherConfigPath: String): Unit
Creates and runs a StarvationDetector thread for the given Akka dispatcher defined in config with the
dispatcherConfigPath.Creates and runs a StarvationDetector thread for the given Akka dispatcher defined in config with the
dispatcherConfigPath.Note that a dispatcher will only have one StarvationDetector for it active at a time. If there is another StarvationDetector running, this method does nothing.
- def checkExecutionContext(ec: ExecutionContext, log: LoggingAdapter, config: StarvationDetectorSettings, hasTerminated: BooleanSupplier): Unit
JAVA API
JAVA API
Creates and runs a StarvationDetector thread for the given ExecutionContext. Thread analytics are currently only available for Akka dispatchers.
You need to provide a
hasTerminatedfunction that will be used to figure out if the execution context has shut down to shutdown the starvation detector thread. - def checkExecutionContext(ec: ExecutionContext, log: LoggingAdapter, config: StarvationDetectorSettings, hasTerminated: () => Boolean): Unit
Creates and runs a StarvationDetector thread for the given ExecutionContext.
Creates and runs a StarvationDetector thread for the given ExecutionContext. Thread analytics are currently only available for Akka dispatchers.
You need to provide a
hasTerminatedfunction that will be used to figure out if the execution context has shut down to shutdown the starvation detector thread.Note that an ExecutionContext will only have one StarvationDetector for it active at a time. If there is another StarvationDetector running, this method does nothing.
- def checkInternalDispatcher(provider: ClassicActorSystemProvider, config: StarvationDetectorSettings): Unit
Creates and runs a StarvationDetector thread for the internal dispatcher of the system with custom configuration.
Creates and runs a StarvationDetector thread for the internal dispatcher of the system with custom configuration. Akka 2.6 introduced this dispatcher for internal tasks like clustering. If there is no internal dispatcher, does nothing.
- def checkInternalDispatcher(provider: ClassicActorSystemProvider): Unit
Creates and runs a StarvationDetector thread for the internal dispatcher of the system.
Creates and runs a StarvationDetector thread for the internal dispatcher of the system. Akka 2.6 introduced this dispatcher for internal tasks like clustering. If there is no internal dispatcher, does nothing.
- def checkSystemDispatcher(provider: ClassicActorSystemProvider, config: StarvationDetectorSettings): Unit
Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e.
Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e. akka.actor.default-dispatcher, with custom configuration.
- def checkSystemDispatcher(provider: ClassicActorSystemProvider): Unit
Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e.
Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e. akka.actor.default-dispatcher.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)