public class StarvationDetector
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
StarvationDetector.StarvationDetectorThread
INTERNAL API
|
static class |
StarvationDetector.UnsupportedDispatcherException |
static class |
StarvationDetector.UnsupportedDispatcherException$ |
| Constructor and Description |
|---|
StarvationDetector() |
| 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.
|
public static void checkSystemDispatcher(akka.actor.ActorSystem system)
system - (undocumented)public static void checkSystemDispatcher(akka.actor.ActorSystem system,
StarvationDetectorSettings config)
system - (undocumented)config - (undocumented)public static void checkExecutionContext(scala.concurrent.ExecutionContext ec,
akka.event.LoggingAdapter log,
StarvationDetectorSettings config,
scala.Function0<java.lang.Object> hasTerminated)
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.
ec - (undocumented)log - (undocumented)config - (undocumented)hasTerminated - (undocumented)public static void checkExecutionContext(scala.concurrent.ExecutionContext ec,
akka.event.LoggingAdapter log,
StarvationDetectorSettings config,
java.util.function.BooleanSupplier 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.
ec - (undocumented)log - (undocumented)config - (undocumented)hasTerminated - (undocumented)