Package org.apache.flink.util.concurrent

Interface Summary

Interface	Description
FutureConsumerWithException<T,E extends Throwable>	A checked extension of the Consumer interface which rethrows exceptions wrapped in a CompletionException.
RetryStrategy	Interface that encapsulates retry logic.
ScheduledExecutor	Extension for the Executor interface which is enriched by method for scheduling tasks in the future.

Class Summary

Class	Description
Executors	Collection of Executor and ExecutorService implementations.
ExecutorThreadFactory	A thread factory intended for use by critical thread pools.
ExecutorThreadFactory.Builder	Builder for ExecutorThreadFactory.
ExponentialBackoffRetryStrategy	An implementation of RetryStrategy that retries that has an exponential backoff with a cap.
FixedRetryStrategy	An implementation of RetryStrategy that retries at a fixed delay.
FutureUtils	A collection of utilities that expand the usage of CompletableFuture.
FutureUtils.ConjunctFuture<T>	A future that is complete once multiple other futures completed.
IgnoreShutdownRejectedExecutionHandler	Rejected executions are ignored or logged in debug if the executor is shutdown.
NeverCompleteFuture	A future that never completes.
ScheduledExecutorServiceAdapter	Adapter class for a ScheduledExecutorService which shall be used as a ScheduledExecutor.
SeparateThreadExecutor	An Executor that runs every runnable in a separate thread.
ThreadUtils	ThreadUtils collects helper methods in the context of threading.

Exception Summary

Exception	Description
FutureUtils.RetryException	Exception with which the returned future is completed if the FutureUtils.retry(Supplier, int, Executor) operation fails.