Packages

o

akka.diagnostics

StarvationDetector

object StarvationDetector

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. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. 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.

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

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

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

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

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

  11. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  15. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped