com.lightbend.akka.diagnostics

Class StarvationDetector$

java.lang.Object

com.lightbend.akka.diagnostics.StarvationDetector$

public class StarvationDetector$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static StarvationDetector$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
StarvationDetector$()

Method Summary

Modifier and Type	Method and Description
void	checkExecutionContext(scala.concurrent.ExecutionContext ec, akka.event.LoggingAdapter log, StarvationDetectorSettings config, java.util.function.BooleanSupplier hasTerminated) JAVA API
void	checkExecutionContext(scala.concurrent.ExecutionContext ec, akka.event.LoggingAdapter log, StarvationDetectorSettings config, scala.Function0<java.lang.Object> hasTerminated) Creates and runs a StarvationDetector thread for the given ExecutionContext.
void	checkSystemDispatcher(akka.actor.ActorSystem system) Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e.
void	checkSystemDispatcher(akka.actor.ActorSystem system, StarvationDetectorSettings config) Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final StarvationDetector$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

StarvationDetector$

public StarvationDetector$()

Method Detail

checkSystemDispatcher

public void checkSystemDispatcher(akka.actor.ActorSystem system)

Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e. akka.actor.default-dispatcher.

Parameters:

system - (undocumented)

checkSystemDispatcher

public void checkSystemDispatcher(akka.actor.ActorSystem system,
                                  StarvationDetectorSettings config)

Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e. akka.actor.default-dispatcher, with custom configuration.

Parameters:

system - (undocumented)

config - (undocumented)

checkExecutionContext

public void checkExecutionContext(scala.concurrent.ExecutionContext ec,
                                  akka.event.LoggingAdapter log,
                                  StarvationDetectorSettings config,
                                  scala.Function0<java.lang.Object> hasTerminated)

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.

Parameters:

ec - (undocumented)

log - (undocumented)

config - (undocumented)

hasTerminated - (undocumented)

checkExecutionContext

public void checkExecutionContext(scala.concurrent.ExecutionContext ec,
                                  akka.event.LoggingAdapter log,
                                  StarvationDetectorSettings config,
                                  java.util.function.BooleanSupplier hasTerminated)

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.

Parameters:

ec - (undocumented)

log - (undocumented)

config - (undocumented)

hasTerminated - (undocumented)