org.apache.flink.fs.s3.common.utils

Class BackPressuringExecutor

java.lang.Object

org.apache.flink.fs.s3.common.utils.BackPressuringExecutor

All Implemented Interfaces:

Executor

@Internal
public final class BackPressuringExecutor
extends Object
implements Executor

An executor decorator that allows only a certain number of concurrent executions. The execute(Runnable) method blocks once that number of executions is exceeded.

Constructor Summary

Constructors

Constructor and Description
BackPressuringExecutor(Executor delegate, int numConcurrentExecutions)

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

BackPressuringExecutor

public BackPressuringExecutor(Executor delegate,
                              int numConcurrentExecutions)

Method Detail

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor