Interface ComponentMainThreadExecutor
-
- All Superinterfaces:
Executor
,ScheduledExecutor
- All Known Implementing Classes:
ComponentMainThreadExecutor.DummyComponentMainThreadExecutor
,RpcEndpoint.MainThreadExecutor
public interface ComponentMainThreadExecutor extends ScheduledExecutor
Interface for an executor that runs tasks in the main thread of anRpcEndpoint
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
ComponentMainThreadExecutor.DummyComponentMainThreadExecutor
Dummy implementation of ComponentMainThreadExecutor.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
assertRunningInMainThread()
Returns true if the method was called in the thread of this executor.-
Methods inherited from interface org.apache.flink.util.concurrent.ScheduledExecutor
schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay
-
-