Package org.apache.flink.runtime.concurrent

Interface Summary

Interface	Description
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 implementations.
FutureUtils	A collection of utilities that expand the usage of CompletableFuture.
FutureUtils.ConjunctFuture<T>	A future that is complete once multiple other futures completed.
ScheduledExecutorServiceAdapter	Adapter class for a ScheduledExecutorService which shall be used as a ScheduledExecutor.

Exception Summary

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