Package org.apache.cassandra.concurrent

Class ScheduledExecutors

java.lang.Object

org.apache.cassandra.concurrent.ScheduledExecutors

public class ScheduledExecutors
extends java.lang.Object

Centralized location for shared executors

Field Summary

Fields

Modifier and Type	Field	Description
static ScheduledExecutorPlus	nonPeriodicTasks	This executor is used for tasks that can have longer execution times, and usually are non periodic.
static ScheduledExecutorPlus	optionalTasks	This executor is used for tasks that do not need to be waited for on shutdown/drain.
static ScheduledExecutorPlus	scheduledFastTasks	This pool is used for periodic fast (sub-microsecond) tasks.
static ScheduledExecutorPlus	scheduledTasks	This pool is used for periodic short (sub-second) tasks.

Constructor Summary

Constructors

Constructor	Description
ScheduledExecutors()

Method Summary

Modifier and Type	Method	Description
static void	shutdownNowAndWait(long timeout, java.util.concurrent.TimeUnit unit)

Methods inherited from class java.lang.Object

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

Field Detail

scheduledFastTasks

public static final ScheduledExecutorPlus scheduledFastTasks

This pool is used for periodic fast (sub-microsecond) tasks.

scheduledTasks

public static final ScheduledExecutorPlus scheduledTasks

This pool is used for periodic short (sub-second) tasks.

nonPeriodicTasks

public static final ScheduledExecutorPlus nonPeriodicTasks

This executor is used for tasks that can have longer execution times, and usually are non periodic.

optionalTasks

public static final ScheduledExecutorPlus optionalTasks

This executor is used for tasks that do not need to be waited for on shutdown/drain.

Constructor Detail

ScheduledExecutors

public ScheduledExecutors()

Method Detail

shutdownNowAndWait

public static void shutdownNowAndWait(long timeout,
                                      java.util.concurrent.TimeUnit unit)
                               throws java.lang.InterruptedException,
                                      java.util.concurrent.TimeoutException

Throws:

java.lang.InterruptedException

java.util.concurrent.TimeoutException