azkaban.utils

Class ExecutorServiceUtils

java.lang.Object

azkaban.utils.ExecutorServiceUtils

public class ExecutorServiceUtils
extends java.lang.Object

Executor service related utilities.

Constructor Summary

Constructors

Constructor and Description
ExecutorServiceUtils()

Method Summary

Modifier and Type	Method and Description
void	gracefulShutdown(java.util.concurrent.ExecutorService service, java.time.Duration timeout) Gracefully shuts down the given executor service.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorServiceUtils

public ExecutorServiceUtils()

Method Detail

gracefulShutdown

public void gracefulShutdown(java.util.concurrent.ExecutorService service,
                             java.time.Duration timeout)
                      throws java.lang.InterruptedException

Gracefully shuts down the given executor service.

Adopted from the Oracle JAVA Documentation.

Parameters:

service - the service to shutdown

timeout - max wait time for the tasks to shutdown. Note that the max wait time is 2 times this value due to the two stages shutdown strategy.

Throws:

java.lang.InterruptedException - if the current thread is interrupted