org.apache.paimon.utils

Class ExecutorUtils

java.lang.Object

org.apache.paimon.utils.ExecutorUtils

public class ExecutorUtils
extends Object

Utilities for Executors.

Constructor Summary

Constructors

Constructor and Description
ExecutorUtils()

Method Summary

Modifier and Type	Method and Description
static void	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 void 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

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