Packages

o

akka.diagnostics

StarvationDetector

object StarvationDetector

Source
StarvationDetector.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StarvationDetector
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final case class UnsupportedDispatcherException(msg: String) extends RuntimeException with NoStackTrace with Product with Serializable

Value Members

  1. 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.

  2. 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.

  3. 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 hasTerminated function that will be used to figure out if the execution context has shut down to shutdown the starvation detector thread.

  4. 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 hasTerminated function 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.

  5. 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.

  6. 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.

  7. 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.

  8. 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.