Package org.apache.pekko.dispatch

Class ExecutionContexts

java.lang.Object
org.apache.pekko.dispatch.ExecutionContexts
public class ExecutionContexts extends Object
ExecutionContexts is the Java API for ExecutionContexts

  • Constructor Summary

    Constructors
    Constructor
    Description
    ExecutionContexts()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static scala.concurrent.ExecutionContextExecutor
    fromExecutor(Executor executor)
    Returns a new ExecutionContextExecutor which will delegate execution to the underlying Executor, and which will use the default error reporter.
    static scala.concurrent.ExecutionContextExecutor
    fromExecutor(Executor executor, Procedure<Throwable> errorReporter)
    Returns a new ExecutionContextExecutor which will delegate execution to the underlying Executor, and which will use the provided error reporter.
    static scala.concurrent.ExecutionContextExecutorService
    fromExecutorService(ExecutorService executorService)
    Returns a new ExecutionContextExecutorService which will delegate execution to the underlying ExecutorService, and which will use the default error reporter.
    static scala.concurrent.ExecutionContextExecutorService
    fromExecutorService(ExecutorService executorService, Procedure<Throwable> errorReporter)
    Returns a new ExecutionContextExecutorService which will delegate execution to the underlying ExecutorService, and which will use the provided error reporter.
    static scala.concurrent.ExecutionContextExecutor
    global()
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ExecutionContexts

      public ExecutionContexts()

  • Method Details

    • fromExecutor

      public static scala.concurrent.ExecutionContextExecutor fromExecutor(Executor executor)
      Returns a new ExecutionContextExecutor which will delegate execution to the underlying Executor, and which will use the default error reporter.

      Parameters:
      executor - the Executor which will be used for the ExecutionContext
      Returns:
      a new ExecutionContext

    • fromExecutor

      public static scala.concurrent.ExecutionContextExecutor fromExecutor(Executor executor, Procedure<Throwable> errorReporter)
      Returns a new ExecutionContextExecutor which will delegate execution to the underlying Executor, and which will use the provided error reporter.

      Parameters:
      executor - the Executor which will be used for the ExecutionContext
      errorReporter - a Procedure that will log any exceptions passed to it
      Returns:
      a new ExecutionContext

    • fromExecutorService

      public static scala.concurrent.ExecutionContextExecutorService fromExecutorService(ExecutorService executorService)
      Returns a new ExecutionContextExecutorService which will delegate execution to the underlying ExecutorService, and which will use the default error reporter.

      Parameters:
      executorService - the ExecutorService which will be used for the ExecutionContext
      Returns:
      a new ExecutionContext

    • fromExecutorService

      public static scala.concurrent.ExecutionContextExecutorService fromExecutorService(ExecutorService executorService, Procedure<Throwable> errorReporter)
      Returns a new ExecutionContextExecutorService which will delegate execution to the underlying ExecutorService, and which will use the provided error reporter.

      Parameters:
      executorService - the ExecutorService which will be used for the ExecutionContext
      errorReporter - a Procedure that will log any exceptions passed to it
      Returns:
      a new ExecutionContext

    • global

      public static scala.concurrent.ExecutionContextExecutor global()
      Returns:
      a reference to the global ExecutionContext