public class StripedExecutor extends Object implements ExecutorService
| Constructor and Description |
|---|
StripedExecutor(int cnt,
String igniteInstanceName,
String poolName,
IgniteLogger log) |
| 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)
cnt - Count.igniteInstanceName - Node name.poolName - Pool name.log - Logger.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.2.0 Release Date : September 15 2017