public class StripedExecutor extends Object implements ExecutorService
| Constructor and Description |
|---|
StripedExecutor(int cnt,
String gridName,
String poolName,
IgniteLogger log)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
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() |
<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 gridName,
String poolName,
IgniteLogger log)
cnt - Count.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()
@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. 1.9.0 Release Date : March 2 2017