org.apache.flink.runtime.concurrent

Class Executors

java.lang.Object

org.apache.flink.runtime.concurrent.Executors

public class Executors
extends Object

Collection of Executor implementations.

Constructor Summary

Constructors

Constructor and Description
Executors()

Method Summary

Modifier and Type	Method and Description
static scala.concurrent.ExecutionContext	directExecutionContext() Return a direct execution context.
static Executor	directExecutor() Return a direct executor.

Methods inherited from class java.lang.Object

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

Constructor Detail

Executors

public Executors()

Method Detail

directExecutor

public static Executor directExecutor()

Return a direct executor. The direct executor directly executes the runnable in the calling thread.

Returns:

Direct executor

directExecutionContext

public static scala.concurrent.ExecutionContext directExecutionContext()

Return a direct execution context. The direct execution context executes the runnable directly in the calling thread.

Returns:

Direct execution context.