Uses of Interface
org.apache.ignite.lang.IgniteRunnable

Packages that use IgniteRunnable

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.datastructures
org.apache.ignite.internal.util.lang
org.apache.ignite.internal.util.lang.gridfunc	Contains utilities classes for GridFunc.
org.apache.ignite.internal.util.nio	NIO server interfaces and common utility classes for NIO.
org.apache.ignite.internal.util.typedef	Contains typedefs definitions for frequently used classes.
org.apache.ignite.spi.communication	Contains APIs for grid communication SPI.
org.apache.ignite.spi.communication.tcp	Contains default TCP/IP-based implementation for communication SPI.

Uses of IgniteRunnable in org.apache.ignite

Methods in org.apache.ignite with parameters of type IgniteRunnable

Modifier and Type	Method and Description
void	IgniteCompute.affinityRun(Collection<String> cacheNames, int partId, IgniteRunnable job) Executes given job on the node where partition is located (the partition is primary on the node) It's guaranteed that the data of all the partitions of all participating caches, the affinity key belongs to, will present on the destination node throughout the job execution.
void	IgniteCompute.affinityRun(Collection<String> cacheNames, Object affKey, IgniteRunnable job) Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).
void	IgniteSet.affinityRun(IgniteRunnable job) Executes given job on collocated set on the node where the set is located (a.k.a. affinity co-location).
void	IgniteQueue.affinityRun(IgniteRunnable job) Executes given job on collocated queue on the node where the queue is located (a.k.a. affinity co-location).
void	IgniteCompute.affinityRun(String cacheName, Object affKey, IgniteRunnable job) Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).
IgniteFuture<Void>	IgniteCompute.affinityRunAsync(Collection<String> cacheNames, int partId, IgniteRunnable job) Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.
IgniteFuture<Void>	IgniteCompute.affinityRunAsync(Collection<String> cacheNames, Object affKey, IgniteRunnable job) Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).
IgniteFuture<Void>	IgniteCompute.affinityRunAsync(String cacheName, Object affKey, IgniteRunnable job) Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).
void	IgniteCompute.broadcast(IgniteRunnable job) Broadcasts given job to all nodes in the cluster group.
IgniteFuture<Void>	IgniteCompute.broadcastAsync(IgniteRunnable job) Broadcasts given job asynchronously to all nodes in the cluster group.
void	IgniteCompute.run(IgniteRunnable job) Executes provided job on a node within the underlying cluster group.
IgniteFuture<Void>	IgniteCompute.runAsync(IgniteRunnable job) Executes provided job asynchronously on a node within the underlying cluster group.

Method parameters in org.apache.ignite with type arguments of type IgniteRunnable

Modifier and Type	Method and Description
void	IgniteCompute.run(Collection<? extends IgniteRunnable> jobs) Executes collection of jobs on grid nodes within the underlying cluster group.
IgniteFuture<Void>	IgniteCompute.runAsync(Collection<? extends IgniteRunnable> jobs) Executes collection of jobs asynchronously on grid nodes within the underlying cluster group.

Uses of IgniteRunnable in org.apache.ignite.internal

Methods in org.apache.ignite.internal with parameters of type IgniteRunnable

Modifier and Type	Method and Description
void	IgniteComputeImpl.affinityRun(Collection<String> cacheNames, int partId, IgniteRunnable job) Executes given job on the node where partition is located (the partition is primary on the node) It's guaranteed that the data of all the partitions of all participating caches, the affinity key belongs to, will present on the destination node throughout the job execution.
void	IgniteComputeImpl.affinityRun(Collection<String> cacheNames, Object affKey, IgniteRunnable job) Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).
void	IgniteComputeImpl.affinityRun(String cacheName, Object affKey, IgniteRunnable job) Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).
IgniteFuture<Void>	IgniteComputeImpl.affinityRunAsync(Collection<String> cacheNames, int partId, IgniteRunnable job) Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.
IgniteFuture<Void>	IgniteComputeImpl.affinityRunAsync(Collection<String> cacheNames, Object affKey, IgniteRunnable job) Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).
IgniteFuture<Void>	IgniteComputeImpl.affinityRunAsync(String cacheName, Object affKey, IgniteRunnable job) Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).
void	IgniteComputeImpl.broadcast(IgniteRunnable job) Broadcasts given job to all nodes in the cluster group.
IgniteFuture<Void>	IgniteComputeImpl.broadcastAsync(IgniteRunnable job) Broadcasts given job asynchronously to all nodes in the cluster group.
void	IgniteComputeImpl.run(IgniteRunnable job) Executes provided job on a node within the underlying cluster group.
IgniteFuture<Void>	IgniteComputeImpl.runAsync(IgniteRunnable job) Executes provided job asynchronously on a node within the underlying cluster group.

Method parameters in org.apache.ignite.internal with type arguments of type IgniteRunnable

Modifier and Type	Method and Description
void	IgniteComputeImpl.run(Collection<? extends IgniteRunnable> jobs) Executes collection of jobs on grid nodes within the underlying cluster group.
IgniteFuture<Void>	IgniteComputeImpl.runAsync(Collection<? extends IgniteRunnable> jobs) Executes collection of jobs asynchronously on grid nodes within the underlying cluster group.

Uses of IgniteRunnable in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache with parameters of type IgniteRunnable

Modifier and Type	Method and Description
void	WalStateManager.WALDisableContext.execute(IgniteRunnable cls)
void	WalStateManager.runWithOutWAL(IgniteRunnable cls) None record will be logged in closure call.

Uses of IgniteRunnable in org.apache.ignite.internal.processors.datastructures

Methods in org.apache.ignite.internal.processors.datastructures with parameters of type IgniteRunnable

Modifier and Type	Method and Description
void	GridCacheQueueProxy.affinityRun(IgniteRunnable job) Executes given job on collocated queue on the node where the queue is located (a.k.a. affinity co-location).
void	GridCacheQueueAdapter.affinityRun(IgniteRunnable job) Executes given job on collocated queue on the node where the queue is located (a.k.a. affinity co-location).
void	GridCacheSetImpl.affinityRun(IgniteRunnable job) Executes given job on collocated set on the node where the set is located (a.k.a. affinity co-location).
void	GridCacheSetProxy.affinityRun(IgniteRunnable job) Executes given job on collocated set on the node where the set is located (a.k.a. affinity co-location).

Uses of IgniteRunnable in org.apache.ignite.internal.util.lang

Classes in org.apache.ignite.internal.util.lang that implement IgniteRunnable

Modifier and Type	Class and Description
class	GridAbsClosure Defines a convenient absolute, i.e.
class	GridAbsClosureX Convenient abs-closure subclass that allows for thrown grid exception.

Uses of IgniteRunnable in org.apache.ignite.internal.util.lang.gridfunc

Classes in org.apache.ignite.internal.util.lang.gridfunc that implement IgniteRunnable

Modifier and Type	Class and Description
class	NoOpClosure Absolute closure that does nothing.
class	RunnableWrapperClosure Closure that wraps given runnable.

Uses of IgniteRunnable in org.apache.ignite.internal.util.nio

Classes in org.apache.ignite.internal.util.nio that implement IgniteRunnable

Modifier and Type	Class and Description
class	GridNioMessageTracker Message tracker.

Methods in org.apache.ignite.internal.util.nio that return IgniteRunnable

Modifier and Type	Method and Description
static IgniteRunnable	GridNioBackPressureControl.threadTracker()

Methods in org.apache.ignite.internal.util.nio with parameters of type IgniteRunnable

Modifier and Type	Method and Description
static void	GridNioBackPressureControl.threadProcessingMessage(boolean processing, IgniteRunnable tracker)

Uses of IgniteRunnable in org.apache.ignite.internal.util.typedef

Classes in org.apache.ignite.internal.util.typedef that implement IgniteRunnable

Modifier and Type	Class and Description
class	CA Defines alias for GridAbsClosure by extending it.
class	CAX Defines alias for GridAbsClosureX by extending it.

Uses of IgniteRunnable in org.apache.ignite.spi.communication

Methods in org.apache.ignite.spi.communication with parameters of type IgniteRunnable

Modifier and Type	Method and Description
void	CommunicationListener.onMessage(UUID nodeId, T msg, IgniteRunnable msgC) NOTE: CommunicationSpi should ignore very first 4 bytes received from sender node and pass the rest of the received message to the listener.

Uses of IgniteRunnable in org.apache.ignite.spi.communication.tcp

Methods in org.apache.ignite.spi.communication.tcp with parameters of type IgniteRunnable

Modifier and Type	Method and Description
protected void	TcpCommunicationSpi.notifyListener(UUID sndId, Message msg, IgniteRunnable msgC)