Package org.apache.cassandra.utils

Class ExecutorUtils

java.lang.Object

org.apache.cassandra.utils.ExecutorUtils

public class ExecutorUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
ExecutorUtils()

Method Summary

Modifier and Type	Method	Description
static void	awaitTermination(long timeout, TimeUnit unit, Collection<?> executors)
static void	awaitTermination(long timeout, TimeUnit unit, ExecutorService... executors)
static void	awaitTerminationUntil(long deadline, Collection<?> executors)
static Runnable	runWithThreadName(Runnable runnable, String threadName)
static void	shutdown(boolean interrupt, Iterable<?> executors)
static void	shutdown(Iterable<?> executors)
static void	shutdown(ExecutorService... executors)
static void	shutdownAndWait(long timeout, TimeUnit unit, Object... executors)
static void	shutdownAndWait(long timeout, TimeUnit unit, Collection<?> executors)
static void	shutdownNow(Iterable<?> executors)
static void	shutdownNow(ExecutorService... executors)
static void	shutdownNowAndWait(long timeout, TimeUnit unit, Object... executors)
static void	shutdownNowAndWait(long timeout, TimeUnit unit, Collection<?> executors)

Methods inherited from class java.lang.Object

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

Constructor Details

ExecutorUtils

public ExecutorUtils()

Method Details

runWithThreadName

public static Runnable runWithThreadName(Runnable runnable,
 String threadName)

shutdownNow

public static void shutdownNow(Iterable<?> executors)

shutdown

public static void shutdown(Iterable<?> executors)

shutdown

public static void shutdown(boolean interrupt,
 Iterable<?> executors)

shutdown

public static void shutdown(ExecutorService... executors)

shutdownNow

public static void shutdownNow(ExecutorService... executors)

awaitTermination

public static void awaitTermination(long timeout,
 TimeUnit unit,
 ExecutorService... executors)
                             throws InterruptedException,
TimeoutException

Throws:

InterruptedException

TimeoutException

awaitTermination

public static void awaitTermination(long timeout,
 TimeUnit unit,
 Collection<?> executors)
                             throws InterruptedException,
TimeoutException

Throws:

InterruptedException

TimeoutException

awaitTerminationUntil

public static void awaitTerminationUntil(long deadline,
 Collection<?> executors)
                                  throws InterruptedException,
TimeoutException

Throws:

InterruptedException

TimeoutException

shutdownAndWait

public static void shutdownAndWait(long timeout,
 TimeUnit unit,
 Collection<?> executors)
                            throws TimeoutException,
InterruptedException

Throws:

TimeoutException

InterruptedException

shutdownNowAndWait

public static void shutdownNowAndWait(long timeout,
 TimeUnit unit,
 Collection<?> executors)
                               throws TimeoutException,
InterruptedException

Throws:

TimeoutException

InterruptedException

shutdownAndWait

public static void shutdownAndWait(long timeout,
 TimeUnit unit,
 Object... executors)
                            throws TimeoutException,
InterruptedException

Throws:

TimeoutException

InterruptedException

shutdownNowAndWait

public static void shutdownNowAndWait(long timeout,
 TimeUnit unit,
 Object... executors)
                               throws TimeoutException,
InterruptedException

Throws:

TimeoutException

InterruptedException