Package org.apache.flink.util

Class ExecutorUtils

java.lang.Object

org.apache.flink.util.ExecutorUtils

public class ExecutorUtils
extends Object

Utilities for Executors.

Constructor Summary

Constructors

Constructor	Description
ExecutorUtils()

Method Summary

Modifier and Type	Method	Description
static List<Runnable>	gracefulShutdown(long timeout, TimeUnit unit, ExecutorService... executorServices)	Gracefully shutdown the given ExecutorService.
static CompletableFuture<Void>	nonBlockingShutdown(long timeout, TimeUnit unit, ExecutorService... executorServices)	Shuts the given ExecutorService down in a non-blocking fashion.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorUtils

public ExecutorUtils()

Method Detail

gracefulShutdown

public static List<Runnable> gracefulShutdown(long timeout,
                                              TimeUnit unit,
                                              ExecutorService... executorServices)

Gracefully shutdown the given ExecutorService. The call waits the given timeout that all ExecutorServices terminate. If the ExecutorServices do not terminate in this time, they will be shut down hard.

Parameters:

timeout - to wait for the termination of all ExecutorServices

unit - of the timeout

executorServices - to shut down

Returns:

Tasks that were not executed prior to a ExecutorService.shutdownNow().

nonBlockingShutdown

public static CompletableFuture<Void> nonBlockingShutdown(long timeout,
                                                          TimeUnit unit,
                                                          ExecutorService... executorServices)

Shuts the given ExecutorService down in a non-blocking fashion. The shut down will be executed by a thread from the common fork-join pool.

The executor services will be shut down gracefully for the given timeout period. Afterwards ExecutorService.shutdownNow() will be called.

Parameters:

timeout - before ExecutorService.shutdownNow() is called

unit - time unit of the timeout

executorServices - to shut down

Returns:

Future which is completed once the ExecutorService are shut down