public class StarvationDetector$
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static StarvationDetector$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
| Constructor and Description |
|---|
StarvationDetector$() |
| 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.
|
public static final StarvationDetector$ MODULE$
public void checkSystemDispatcher(akka.actor.ActorSystem system)
system - (undocumented)public void checkSystemDispatcher(akka.actor.ActorSystem system,
StarvationDetectorSettings config)
system - (undocumented)config - (undocumented)public 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 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)