public class StripedExecutor extends Object implements ExecutorService
| Constructor and Description |
|---|
StripedExecutor(int cnt,
String igniteInstanceName,
String poolName,
IgniteLogger log,
Thread.UncaughtExceptionHandler errHnd) |
StripedExecutor(int cnt,
String igniteInstanceName,
String poolName,
IgniteLogger log,
Thread.UncaughtExceptionHandler errHnd,
boolean stealTasks) |
| Modifier and Type | Method and Description |
|---|---|
int |
activeStripesCount() |
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
void |
checkStarvation()
Checks starvation in striped pool.
|
long |
completedTasks() |
void |
execute(int idx,
Runnable cmd)
Execute command.
|
void |
execute(Runnable cmd) |
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks)
Operation not supported.
|
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit)
Operation not supported.
|
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks)
Operation not supported.
|
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit)
Operation not supported.
|
boolean |
isShutdown() |
boolean |
isTerminated() |
int |
queueSize() |
void |
shutdown() |
List<Runnable> |
shutdownNow() |
void |
stop()
Stops executor.
|
int |
stripes() |
boolean[] |
stripesActiveStatuses() |
long[] |
stripesCompletedTasks() |
int[] |
stripesQueueSizes() |
<T> Future<T> |
submit(Callable<T> task)
Operation not supported.
|
Future<?> |
submit(Runnable task)
Operation not supported.
|
<T> Future<T> |
submit(Runnable task,
T res)
Operation not supported.
|
String |
toString() |
public StripedExecutor(int cnt,
String igniteInstanceName,
String poolName,
IgniteLogger log,
Thread.UncaughtExceptionHandler errHnd)
cnt - Count.igniteInstanceName - Node name.poolName - Pool name.log - Logger.errHnd - Exception handler.public StripedExecutor(int cnt,
String igniteInstanceName,
String poolName,
IgniteLogger log,
Thread.UncaughtExceptionHandler errHnd,
boolean stealTasks)
cnt - Count.igniteInstanceName - Node name.poolName - Pool name.log - Logger.errHnd - Exception handler.stealTasks - True to steal tasks.public void checkStarvation()
public int stripes()
public void execute(int idx,
Runnable cmd)
idx - Index.cmd - Command.public void shutdown()
shutdown in interface ExecutorService@NotNull public List<Runnable> shutdownNow()
shutdownNow in interface ExecutorServicepublic boolean awaitTermination(long timeout,
@NotNull
TimeUnit unit)
throws InterruptedException
awaitTermination in interface ExecutorServiceInterruptedExceptionpublic boolean isShutdown()
isShutdown in interface ExecutorServicepublic boolean isTerminated()
isTerminated in interface ExecutorServicepublic void stop()
public int queueSize()
public long completedTasks()
public long[] stripesCompletedTasks()
public boolean[] stripesActiveStatuses()
public int activeStripesCount()
public int[] stripesQueueSizes()
@NotNull public <T> Future<T> submit(@NotNull Runnable task, T res)
submit in interface ExecutorService@NotNull public Future<?> submit(@NotNull Runnable task)
submit in interface ExecutorService@NotNull public <T> Future<T> submit(@NotNull Callable<T> task)
submit in interface ExecutorService@NotNull public <T> List<Future<T>> invokeAll(@NotNull Collection<? extends Callable<T>> tasks) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedException@NotNull public <T> List<Future<T>> invokeAll(@NotNull Collection<? extends Callable<T>> tasks, long timeout, @NotNull TimeUnit unit) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedException@NotNull
public <T> T invokeAny(@NotNull
Collection<? extends Callable<T>> tasks)
throws InterruptedException,
ExecutionException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionpublic <T> T invokeAny(@NotNull
Collection<? extends Callable<T>> tasks,
long timeout,
@NotNull
TimeUnit unit)
throws InterruptedException,
ExecutionException,
TimeoutException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionTimeoutException
Follow @ApacheIgnite
Ignite Fabric : ver. 2.6.0 Release Date : July 10 2018