com.lightbend.akka.diagnostics

Class StarvationDetector

java.lang.Object

com.lightbend.akka.diagnostics.StarvationDetector

public class StarvationDetector
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StarvationDetector.StarvationDetectorThread INTERNAL API
static class	StarvationDetector.UnsupportedDispatcherException
static class	StarvationDetector.UnsupportedDispatcherException$

Constructor Summary

Constructors

Constructor and Description
StarvationDetector()

Method Summary

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

Constructor Detail

StarvationDetector

public StarvationDetector()

Method Detail

checkSystemDispatcher

public static 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 static 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 static 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 static 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)