org.gridgain.grid.kernal.processors.closure

Class GridClosureProcessor

java.lang.Object

org.gridgain.grid.kernal.processors.GridProcessorAdapter

org.gridgain.grid.kernal.processors.closure.GridClosureProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridClosureProcessor
extends GridProcessorAdapter

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridClosureProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
<R> GridFuture<R>	affinityCall(String cacheName, Object affKey, Callable<R> job, Collection<GridNode> nodes)
GridFuture<?>	affinityRun(String cacheName, Object affKey, Runnable job, Collection<GridNode> nodes)
<T,R> GridFuture<Collection<R>>	broadcast(GridClosure<T,R> job, T arg, Collection<GridNode> nodes)
<T,R> GridFuture<Collection<R>>	callAsync(GridClosure<T,R> job, Collection<? extends T> args, Collection<GridNode> nodes)
<T,R> GridFuture<R>	callAsync(GridClosure<T,R> job, T arg, Collection<GridNode> nodes)
<T,R1,R2> GridFuture<R2>	callAsync(GridClosure<T,R1> job, Collection<? extends T> args, GridReducer<R1,R2> rdc, Collection<GridNode> nodes)
<R> GridFuture<R>	callAsync(GridClosureCallMode mode, Callable<R> job, Collection<GridNode> nodes)
<R> GridFuture<R>	callAsync(GridClosureCallMode mode, Callable<R> job, Collection<GridNode> nodes, boolean sys)
<R> GridFuture<Collection<R>>	callAsync(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, Collection<GridNode> nodes)
<R> GridFuture<Collection<R>>	callAsync(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, Collection<GridNode> nodes, boolean sys)
<R> GridFuture<R>	callAsyncNoFailover(GridClosureCallMode mode, Callable<R> job, Collection<GridNode> nodes, boolean sys)
<R> GridFuture<Collection<R>>	callAsyncNoFailover(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, Collection<GridNode> nodes, boolean sys)
<R> GridFuture<R>	callLocalSafe(Callable<R> c) Executes closure on system pool.
<R> GridFuture<R>	callLocalSafe(Callable<R> c, boolean sys) Executes closure on system pool.
<R> GridFuture<R>	callLocalSafe(Callable<R> c, GridClosurePolicy plc) Companion to callLocal(Callable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).
<R1,R2> GridFuture<R2>	forkjoinAsync(GridClosureCallMode mode, Collection<? extends Callable<R1>> jobs, GridReducer<R1,R2> rdc, Collection<GridNode> nodes)
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
GridFuture<?>	runAsync(GridClosureCallMode mode, Collection<? extends Runnable> jobs, Collection<GridNode> nodes)
GridFuture<?>	runAsync(GridClosureCallMode mode, Collection<? extends Runnable> jobs, Collection<GridNode> nodes, boolean sys)
GridFuture<?>	runAsync(GridClosureCallMode mode, Runnable job, Collection<GridNode> nodes)
GridFuture<?>	runAsync(GridClosureCallMode mode, Runnable job, Collection<GridNode> nodes, boolean sys)
GridFuture<?>	runLocalSafe(Runnable c) Executes closure on system pool.
GridFuture<?>	runLocalSafe(Runnable c, boolean sys) Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).
GridFuture<?>	runLocalSafe(Runnable c, GridClosurePolicy plc) Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).
void	start() Starts grid component.

Methods inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

addAttributes, assertParameter, collectDiscoveryData, onDiscoveryDataReceived, onKernalStart, printMemoryStats, stop, toString, validateNode

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GridClosureProcessor

public GridClosureProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws GridException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

GridException - Throws in case of any errors.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

runAsync

public GridFuture<?> runAsync(GridClosureCallMode mode,
                     @Nullable
                     Collection<? extends Runnable> jobs,
                     @Nullable
                     Collection<GridNode> nodes)

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

Returns:

Task execution future.

runAsync

public GridFuture<?> runAsync(GridClosureCallMode mode,
                     @Nullable
                     Collection<? extends Runnable> jobs,
                     @Nullable
                     Collection<GridNode> nodes,
                     boolean sys)

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Task execution future.

runAsync

public GridFuture<?> runAsync(GridClosureCallMode mode,
                     @Nullable
                     Runnable job,
                     @Nullable
                     Collection<GridNode> nodes)

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

Returns:

Task execution future.

runAsync

public GridFuture<?> runAsync(GridClosureCallMode mode,
                     @Nullable
                     Runnable job,
                     @Nullable
                     Collection<GridNode> nodes,
                     boolean sys)

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Task execution future.

forkjoinAsync

public <R1,R2> GridFuture<R2> forkjoinAsync(GridClosureCallMode mode,
                                   @Nullable
                                   Collection<? extends Callable<R1>> jobs,
                                   @Nullable
                                   GridReducer<R1,R2> rdc,
                                   @Nullable
                                   Collection<GridNode> nodes)

Type Parameters:

R1 - Type.

R2 - Type.

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

rdc - Reducer.

nodes - Grid nodes.

Returns:

Reduced result.

callAsync

public <R> GridFuture<Collection<R>> callAsync(GridClosureCallMode mode,
                                      @Nullable
                                      Collection<? extends Callable<R>> jobs,
                                      @Nullable
                                      Collection<GridNode> nodes)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

Returns:

Grid future for collection of closure results.

callAsync

public <R> GridFuture<Collection<R>> callAsync(GridClosureCallMode mode,
                                      @Nullable
                                      Collection<? extends Callable<R>> jobs,
                                      @Nullable
                                      Collection<GridNode> nodes,
                                      boolean sys)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Grid future for collection of closure results.

callAsync

public <R> GridFuture<R> callAsync(GridClosureCallMode mode,
                          @Nullable
                          Callable<R> job,
                          @Nullable
                          Collection<GridNode> nodes)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

Returns:

Grid future for collection of closure results.

affinityCall

public <R> GridFuture<R> affinityCall(@Nullable
                             String cacheName,
                             Object affKey,
                             Callable<R> job,
                             @Nullable
                             Collection<GridNode> nodes)

Parameters:

cacheName - Cache name.

affKey - Affinity key.

job - Job.

nodes - Grid nodes.

Returns:

Job future.

affinityRun

public GridFuture<?> affinityRun(@Nullable
                        String cacheName,
                        Object affKey,
                        Runnable job,
                        @Nullable
                        Collection<GridNode> nodes)

Parameters:

cacheName - Cache name.

affKey - Affinity key.

job - Job.

nodes - Grid nodes.

Returns:

Job future.

callAsyncNoFailover

public <R> GridFuture<R> callAsyncNoFailover(GridClosureCallMode mode,
                                    @Nullable
                                    Callable<R> job,
                                    @Nullable
                                    Collection<GridNode> nodes,
                                    boolean sys)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Grid future for collection of closure results.

callAsyncNoFailover

public <R> GridFuture<Collection<R>> callAsyncNoFailover(GridClosureCallMode mode,
                                                @Nullable
                                                Collection<? extends Callable<R>> jobs,
                                                @Nullable
                                                Collection<GridNode> nodes,
                                                boolean sys)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Grid future for collection of closure results.

callAsync

public <R> GridFuture<R> callAsync(GridClosureCallMode mode,
                          @Nullable
                          Callable<R> job,
                          @Nullable
                          Collection<GridNode> nodes,
                          boolean sys)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Grid future for collection of closure results.

callAsync

public <T,R> GridFuture<R> callAsync(GridClosure<T,R> job,
                            @Nullable
                            T arg,
                            @Nullable
                            Collection<GridNode> nodes)

Parameters:

job - Job closure.

arg - Optional job argument.

nodes - Grid nodes.

Returns:

Grid future for execution result.

broadcast

public <T,R> GridFuture<Collection<R>> broadcast(GridClosure<T,R> job,
                                        @Nullable
                                        T arg,
                                        @Nullable
                                        Collection<GridNode> nodes)

Parameters:

job - Job closure.

arg - Optional job argument.

nodes - Grid nodes.

Returns:

Grid future for execution result.

callAsync

public <T,R> GridFuture<Collection<R>> callAsync(GridClosure<T,R> job,
                                        @Nullable
                                        Collection<? extends T> args,
                                        @Nullable
                                        Collection<GridNode> nodes)

Parameters:

job - Job closure.

args - Job arguments.

nodes - Grid nodes.

Returns:

Grid future for execution result.

callAsync

public <T,R1,R2> GridFuture<R2> callAsync(GridClosure<T,R1> job,
                                 Collection<? extends T> args,
                                 GridReducer<R1,R2> rdc,
                                 @Nullable
                                 Collection<GridNode> nodes)

Parameters:

job - Job closure.

args - Job arguments.

rdc - Reducer.

nodes - Grid nodes.

Returns:

Grid future for execution result.

runLocalSafe

public GridFuture<?> runLocalSafe(Runnable c)

Executes closure on system pool. Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

Returns:

Future.

runLocalSafe

public GridFuture<?> runLocalSafe(Runnable c,
                         boolean sys)

Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

sys - If true, then system pool will be used, otherwise public pool will be used.

Returns:

Future.

runLocalSafe

public GridFuture<?> runLocalSafe(Runnable c,
                         GridClosurePolicy plc)

Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

plc - Policy to choose executor pool.

Returns:

Future.

callLocalSafe

public <R> GridFuture<R> callLocalSafe(Callable<R> c)

Executes closure on system pool. Companion to callLocal(Callable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

Returns:

Future.

callLocalSafe

public <R> GridFuture<R> callLocalSafe(Callable<R> c,
                              boolean sys)

Executes closure on system pool. Companion to callLocal(Callable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

sys - If true, then system pool will be used, otherwise public pool will be used.

Returns:

Future.

callLocalSafe

public <R> GridFuture<R> callLocalSafe(Callable<R> c,
                              GridClosurePolicy plc)

Companion to callLocal(Callable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

plc - Policy to choose executor pool.

Returns:

Future.