Modifier and Type | Class and Description |
---|---|
static interface |
Stage.ExecutorServiceInitialiser |
Enum Constant and Description |
---|
ANTI_ENTROPY |
COUNTER_MUTATION |
GOSSIP |
IMMEDIATE |
INTERNAL_RESPONSE |
MIGRATION |
MISC |
MUTATION |
READ |
REQUEST_RESPONSE |
TRACING |
VIEW_MUTATION |
Modifier and Type | Field and Description |
---|---|
java.lang.String |
jmxName |
static long |
KEEP_ALIVE_SECONDS |
boolean |
shutdownBeforeCommitlog
Set true if this executor should be gracefully shutdown before stopping
the commitlog allocator.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
areMutationExecutorsTerminated() |
void |
execute(java.lang.Runnable command) |
void |
execute(java.lang.Runnable command,
ExecutorLocals locals) |
LocalAwareExecutorService |
executor() |
static Stage |
fromPoolName(java.lang.String stageName) |
int |
getCorePoolSize()
Returns core thread pool size
|
int |
getMaximumPoolSize()
Returns maximum pool size of thread pool.
|
void |
maybeExecuteImmediately(java.lang.Runnable command) |
void |
setCorePoolSize(int newCorePoolSize)
Allows user to resize core thread pool size
|
void |
setMaximumPoolSize(int newMaximumPoolSize)
Allows user to resize maximum size of the thread pool.
|
static void |
shutdownAndAwaitMutatingExecutors(boolean interrupt,
long timeout,
java.util.concurrent.TimeUnit units) |
static void |
shutdownAndWait(long timeout,
java.util.concurrent.TimeUnit units) |
static void |
shutdownNow()
This method shuts down all registered stages.
|
<T> java.util.concurrent.Future<T> |
submit(java.util.concurrent.Callable<T> task) |
java.util.concurrent.Future<?> |
submit(java.lang.Runnable task) |
<T> java.util.concurrent.Future<T> |
submit(java.lang.Runnable task,
T result) |
static Stage |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static Stage[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final Stage READ
public static final Stage MUTATION
public static final Stage COUNTER_MUTATION
public static final Stage VIEW_MUTATION
public static final Stage GOSSIP
public static final Stage REQUEST_RESPONSE
public static final Stage ANTI_ENTROPY
public static final Stage MIGRATION
public static final Stage MISC
public static final Stage TRACING
public static final Stage INTERNAL_RESPONSE
public static final Stage IMMEDIATE
public static final long KEEP_ALIVE_SECONDS
public final java.lang.String jmxName
public final boolean shutdownBeforeCommitlog
public static Stage[] values()
for (Stage c : Stage.values()) System.out.println(c);
public static Stage valueOf(java.lang.String name)
name
- the name of the enum constant to be returned.java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is nullpublic static Stage fromPoolName(java.lang.String stageName)
public void execute(java.lang.Runnable command)
public void execute(java.lang.Runnable command, ExecutorLocals locals)
public void maybeExecuteImmediately(java.lang.Runnable command)
public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> task)
public java.util.concurrent.Future<?> submit(java.lang.Runnable task)
public <T> java.util.concurrent.Future<T> submit(java.lang.Runnable task, T result)
public LocalAwareExecutorService executor()
public static void shutdownNow()
public static void shutdownAndAwaitMutatingExecutors(boolean interrupt, long timeout, java.util.concurrent.TimeUnit units) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
java.lang.InterruptedException
java.util.concurrent.TimeoutException
public static boolean areMutationExecutorsTerminated()
public static void shutdownAndWait(long timeout, java.util.concurrent.TimeUnit units) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
java.lang.InterruptedException
java.util.concurrent.TimeoutException
public int getCorePoolSize()
public void setCorePoolSize(int newCorePoolSize)
public int getMaximumPoolSize()
public void setMaximumPoolSize(int newMaximumPoolSize)
Copyright © 2009-2022 The Apache Software Foundation