org.apache.flink.runtime.rpc

Class RpcEndpoint.MainThreadExecutor

java.lang.Object

org.apache.flink.runtime.rpc.RpcEndpoint.MainThreadExecutor

All Implemented Interfaces:

Executor

Enclosing class:

RpcEndpoint

protected static class RpcEndpoint.MainThreadExecutor
extends Object
implements Executor

Executor which executes runnables in the main thread context.

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable runnable)

Methods inherited from class java.lang.Object

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

Method Detail

execute

public void execute(@Nonnull
                    Runnable runnable)

Specified by:

execute in interface Executor