public class GridClosureProcessor extends GridProcessorAdapter
| Modifier and Type | Class and Description |
|---|---|
static class |
GridClosureProcessor.C1<T,R> |
static class |
GridClosureProcessor.C1MLA<T,R> |
static class |
GridClosureProcessor.C2<R> |
static class |
GridClosureProcessor.C2MLA<R> |
static class |
GridClosureProcessor.C4 |
static class |
GridClosureProcessor.C4MLA |
GridComponent.DiscoveryDataExchangeTypectx, diagnosticLog, log| Constructor and Description |
|---|
GridClosureProcessor(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
<R> ComputeTaskInternalFuture<R> |
affinityCall(@NotNull Collection<String> cacheNames,
int partId,
Callable<R> job,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
ComputeTaskInternalFuture<?> |
affinityRun(@NotNull Collection<String> cacheNames,
int partId,
Runnable job,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<T,R> IgniteInternalFuture<Collection<R>> |
broadcast(IgniteClosure<T,R> job,
T arg,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<R> ComputeTaskInternalFuture<R> |
callAsync(GridClosureCallMode mode,
@Nullable Callable<R> job,
@Nullable Collection<ClusterNode> nodes) |
<R> ComputeTaskInternalFuture<R> |
callAsync(GridClosureCallMode mode,
Callable<R> job,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
@Nullable String execName) |
<R> ComputeTaskInternalFuture<R> |
callAsync(GridClosureCallMode mode,
@Nullable Callable<R> job,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<R> ComputeTaskInternalFuture<Collection<R>> |
callAsync(GridClosureCallMode mode,
@Nullable Collection<? extends Callable<R>> jobs,
@Nullable Collection<ClusterNode> nodes) |
<R> ComputeTaskInternalFuture<Collection<R>> |
callAsync(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
@Nullable String execName) |
<R> ComputeTaskInternalFuture<Collection<R>> |
callAsync(GridClosureCallMode mode,
@Nullable Collection<? extends Callable<R>> jobs,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<T,R> ComputeTaskInternalFuture<Collection<R>> |
callAsync(IgniteClosure<T,R> job,
@Nullable Collection<? extends T> args,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<T,R> ComputeTaskInternalFuture<R> |
callAsync(IgniteClosure<T,R> job,
T arg,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<T,R1,R2> ComputeTaskInternalFuture<R2> |
callAsync(IgniteClosure<T,R1> job,
Collection<? extends T> args,
IgniteReducer<R1,R2> rdc,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<R> IgniteInternalFuture<R> |
callAsyncNoFailover(GridClosureCallMode mode,
@Nullable Callable<R> job,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
long timeout,
boolean skipAuth) |
<R> IgniteInternalFuture<Collection<R>> |
callAsyncNoFailover(GridClosureCallMode mode,
@Nullable Collection<? extends Callable<R>> jobs,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
long timeout) |
<R> IgniteInternalFuture<R> |
callLocal(@Nullable Callable<R> c,
byte plc) |
<R> IgniteInternalFuture<R> |
callLocalSafe(Callable<R> c)
Executes closure on system pool.
|
<R> IgniteInternalFuture<R> |
callLocalSafe(Callable<R> c,
boolean sys)
Executes closure on system pool.
|
<R> IgniteInternalFuture<R> |
callLocalSafe(Callable<R> c,
byte plc)
Companion to
callLocal(Callable, boolean) but in case of rejected execution re-runs
the closure in the current thread (blocking). |
<R1,R2> ComputeTaskInternalFuture<R2> |
forkjoinAsync(GridClosureCallMode mode,
Collection<? extends Callable<R1>> jobs,
IgniteReducer<R1,R2> rdc,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
void |
onKernalStop(boolean cancel)
Callback to notify that kernal is about to stop.
|
ComputeTaskInternalFuture<?> |
runAsync(GridClosureCallMode mode,
Collection<? extends Runnable> jobs,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
@Nullable String execName) |
ComputeTaskInternalFuture<?> |
runAsync(GridClosureCallMode mode,
@Nullable Collection<? extends Runnable> jobs,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
ComputeTaskInternalFuture<?> |
runAsync(GridClosureCallMode mode,
Runnable job,
@Nullable Collection<ClusterNode> nodes) |
ComputeTaskInternalFuture<?> |
runAsync(GridClosureCallMode mode,
Runnable job,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
@Nullable String execName) |
ComputeTaskInternalFuture<?> |
runAsync(GridClosureCallMode mode,
Runnable job,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
IgniteInternalFuture<?> |
runLocal(@Nullable Runnable c,
byte plc) |
IgniteInternalFuture<?> |
runLocalSafe(Runnable c)
Executes closure on system pool.
|
IgniteInternalFuture<?> |
runLocalSafe(Runnable c,
boolean sys)
In case of rejected execution re-runs the closure in the current thread (blocking).
|
IgniteInternalFuture<?> |
runLocalSafe(Runnable c,
byte plc)
In case of rejected execution re-runs the closure in the current thread (blocking).
|
void |
runLocalWithThreadPolicy(IgniteThread thread,
Runnable c) |
void |
start()
Starts grid component.
|
assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onReconnected, printMemoryStats, stop, toString, validateNode, validateNodepublic GridClosureProcessor(GridKernalContext ctx)
ctx - Kernal context.public void start()
throws IgniteCheckedException
start in interface GridComponentstart in class GridProcessorAdapterIgniteCheckedException - Throws in case of any errors.public void onKernalStop(boolean cancel)
onKernalStop in interface GridComponentonKernalStop in class GridProcessorAdaptercancel - Flag indicating whether jobs should be canceled.public ComputeTaskInternalFuture<?> runAsync(GridClosureCallMode mode, @Nullable @Nullable Collection<? extends Runnable> jobs, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName)
mode - Distribution mode.jobs - Closures to execute.nodes - Grid nodes.execName - Custom executor name.public ComputeTaskInternalFuture<?> runAsync(GridClosureCallMode mode, Collection<? extends Runnable> jobs, @Nullable @Nullable Collection<ClusterNode> nodes, boolean sys, @Nullable @Nullable String execName)
mode - Distribution mode.jobs - Closures to execute.nodes - Grid nodes.sys - If true, then system pool will be used.execName - Custom executor name.public ComputeTaskInternalFuture<?> runAsync(GridClosureCallMode mode, Runnable job, @Nullable @Nullable Collection<ClusterNode> nodes)
mode - Distribution mode.job - Closure to execute.nodes - Grid nodes.public ComputeTaskInternalFuture<?> runAsync(GridClosureCallMode mode, Runnable job, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName)
mode - Distribution mode.job - Closure to execute.nodes - Grid nodes.execName - Custom executor name.public ComputeTaskInternalFuture<?> runAsync(GridClosureCallMode mode, Runnable job, @Nullable @Nullable Collection<ClusterNode> nodes, boolean sys, @Nullable @Nullable String execName)
mode - Distribution mode.job - Closure to execute.nodes - Grid nodes.sys - If true, then system pool will be used.execName - Custom executor name.public <R1,R2> ComputeTaskInternalFuture<R2> forkjoinAsync(GridClosureCallMode mode, Collection<? extends Callable<R1>> jobs, IgniteReducer<R1,R2> rdc, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName)
R1 - Type.R2 - Type.mode - Distribution mode.jobs - Closures to execute.rdc - Reducer.nodes - Grid nodes.execName - Custom executor name.public <R> ComputeTaskInternalFuture<Collection<R>> callAsync(GridClosureCallMode mode, @Nullable @Nullable Collection<? extends Callable<R>> jobs, @Nullable @Nullable Collection<ClusterNode> nodes)
R - Type.mode - Distribution mode.jobs - Closures to execute.nodes - Grid nodes.public <R> ComputeTaskInternalFuture<Collection<R>> callAsync(GridClosureCallMode mode, @Nullable @Nullable Collection<? extends Callable<R>> jobs, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName)
R - Type.mode - Distribution mode.jobs - Closures to execute.nodes - Grid nodes.execName - Custom executor name.public <R> ComputeTaskInternalFuture<Collection<R>> callAsync(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, @Nullable @Nullable Collection<ClusterNode> nodes, boolean sys, @Nullable @Nullable String execName)
R - Type.mode - Distribution mode.jobs - Closures to execute.nodes - Grid nodes.sys - If true, then system pool will be used.execName - Custom executor name.public <R> ComputeTaskInternalFuture<R> callAsync(GridClosureCallMode mode, @Nullable @Nullable Callable<R> job, @Nullable @Nullable Collection<ClusterNode> nodes)
R - Type.mode - Distribution mode.job - Closure to execute.nodes - Grid nodes.public <R> ComputeTaskInternalFuture<R> callAsync(GridClosureCallMode mode, @Nullable @Nullable Callable<R> job, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName)
R - Type.mode - Distribution mode.job - Closure to execute.nodes - Grid nodes.execName - Custom executor name.public <R> ComputeTaskInternalFuture<R> affinityCall(@NotNull @NotNull Collection<String> cacheNames, int partId, Callable<R> job, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName) throws IgniteCheckedException
cacheNames - Cache names.partId - Partition.job - Closure to execute.nodes - Grid nodes.execName - Custom executor name.IgniteCheckedException - If failed.public ComputeTaskInternalFuture<?> affinityRun(@NotNull @NotNull Collection<String> cacheNames, int partId, Runnable job, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName) throws IgniteCheckedException
cacheNames - Cache names.partId - Partition.job - Job.nodes - Grid nodes.execName - Custom executor name.IgniteCheckedException - If failed.public <R> IgniteInternalFuture<R> callAsyncNoFailover(GridClosureCallMode mode, @Nullable @Nullable Callable<R> job, @Nullable @Nullable Collection<ClusterNode> nodes, boolean sys, long timeout, boolean skipAuth)
R - Type.mode - Distribution mode.job - Closure to execute.nodes - Grid nodes.sys - If true, then system pool will be used.timeout - Timeout.skipAuth - Skip authorization check.public <R> IgniteInternalFuture<Collection<R>> callAsyncNoFailover(GridClosureCallMode mode, @Nullable @Nullable Collection<? extends Callable<R>> jobs, @Nullable @Nullable Collection<ClusterNode> nodes, boolean sys, long timeout)
R - Type.mode - Distribution mode.jobs - Closures to execute.nodes - Grid nodes.sys - If true, then system pool will be used.timeout - If greater than 0 limits task execution. Cannot be negative.public <R> ComputeTaskInternalFuture<R> callAsync(GridClosureCallMode mode, Callable<R> job, @Nullable @Nullable Collection<ClusterNode> nodes, boolean sys, @Nullable @Nullable String execName)
R - Type.mode - Distribution mode.job - Closure to execute.nodes - Grid nodes.sys - If true, then system pool will be used.execName - Custom executor name.public <T,R> ComputeTaskInternalFuture<R> callAsync(IgniteClosure<T,R> job, @Nullable T arg, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName)
job - Job closure.arg - Optional job argument.nodes - Grid nodes.execName - Custom executor name.public <T,R> IgniteInternalFuture<Collection<R>> broadcast(IgniteClosure<T,R> job, @Nullable T arg, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName)
job - Job closure.arg - Optional job argument.nodes - Grid nodes.execName - Custom executor name.public <T,R> ComputeTaskInternalFuture<Collection<R>> callAsync(IgniteClosure<T,R> job, @Nullable @Nullable Collection<? extends T> args, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName)
job - Job closure.args - Job arguments.nodes - Grid nodes.execName - Custom executor name.public <T,R1,R2> ComputeTaskInternalFuture<R2> callAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc, @Nullable @Nullable Collection<ClusterNode> nodes, @Nullable @Nullable String execName)
job - Job closure.args - Job arguments.rdc - Reducer.nodes - Grid nodes.execName - Custom executor name.public void runLocalWithThreadPolicy(IgniteThread thread, Runnable c)
thread - Thread.c - Closure.public IgniteInternalFuture<?> runLocal(@Nullable @Nullable Runnable c, byte plc) throws IgniteCheckedException
c - Closure to execute.plc - Whether to run on system or public pool.IgniteCheckedException - Thrown in case of any errors.public IgniteInternalFuture<?> runLocalSafe(Runnable c)
c - Closure to execute.public IgniteInternalFuture<?> runLocalSafe(Runnable c, boolean sys)
c - Closure to execute.sys - If true, then system pool will be used, otherwise public pool will be used.public IgniteInternalFuture<?> runLocalSafe(Runnable c, byte plc)
c - Closure to execute.plc - Policy to choose executor pool.public <R> IgniteInternalFuture<R> callLocal(@Nullable @Nullable Callable<R> c, byte plc) throws IgniteCheckedException
R - Type of closure return value.c - Closure to execute.plc - Whether to run on system or public pool.IgniteCheckedException - Thrown in case of any errors.public <R> IgniteInternalFuture<R> callLocalSafe(Callable<R> c)
callLocal(Callable, boolean)
but in case of rejected execution re-runs the closure in the current thread (blocking).c - Closure to execute.public <R> IgniteInternalFuture<R> callLocalSafe(Callable<R> c, boolean sys)
callLocal(Callable, boolean)
but in case of rejected execution re-runs the closure in the current thread (blocking).c - Closure to execute.sys - If true, then system pool will be used, otherwise public pool will be used.public <R> IgniteInternalFuture<R> callLocalSafe(Callable<R> c, byte plc)
callLocal(Callable, boolean) but in case of rejected execution re-runs
the closure in the current thread (blocking).c - Closure to execute.plc - Policy to choose executor pool.
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020