org.apache.flink.util.concurrent

Class SeparateThreadExecutor

java.lang.Object

org.apache.flink.util.concurrent.SeparateThreadExecutor

All Implemented Interfaces:

Executor

public final class SeparateThreadExecutor
extends Object
implements Executor

An Executor that runs every runnable in a separate thread.

Constructor Summary

Constructors

Constructor and Description
SeparateThreadExecutor(ThreadFactory threadFactory)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SeparateThreadExecutor

public SeparateThreadExecutor(ThreadFactory threadFactory)

Method Detail

execute

public void execute(@Nonnull
                    Runnable command)

Specified by:

execute in interface Executor