org.apache.ignite.internal.processors.cache

Class GridCacheClearAllRunnable<K,V>

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheClearAllRunnable<K,V>

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

GridNearCacheClearAllRunnable

public class GridCacheClearAllRunnable<K,V>
extends Object
implements Runnable

Base runnable for IgniteInternalCache.clearLocally(boolean, boolean, boolean) routine.

Field Summary

Fields

Modifier and Type	Field and Description
protected GridCacheAdapter<K,V>	cache Cache to be cleared.
protected GridCacheContext<K,V>	ctx Cache context.
protected int	id Mod for the given runnable.
protected IgniteLogger	log Logger.
protected GridCacheVersion	obsoleteVer Obsolete version.
protected boolean	readers Whether to clear readers.
protected int	totalCnt Mods count across all spawned clearLocally runnables.

Constructor Summary

Constructors

Constructor and Description
GridCacheClearAllRunnable(GridCacheAdapter<K,V> cache, GridCacheVersion obsoleteVer, int id, int totalCnt, boolean readers) Constructor.

Method Summary

Modifier and Type	Method and Description
protected void	clearEntry(GridCacheEntryEx e) Clear entry from cache.
int	id()
protected boolean	owns(KeyCacheObject key) Check whether this worker owns particular key.
boolean	readers()
void	run()
String	toString()
int	totalCount()

Methods inherited from class java.lang.Object

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

Field Detail

cache

protected final GridCacheAdapter<K,V> cache

Cache to be cleared.

obsoleteVer

protected final GridCacheVersion obsoleteVer

Obsolete version.

id

protected final int id

Mod for the given runnable.

totalCnt

protected final int totalCnt

Mods count across all spawned clearLocally runnables.

readers

protected final boolean readers

Whether to clear readers.

ctx

protected final GridCacheContext<K,V> ctx

Cache context.

log

protected final IgniteLogger log

Logger.

Constructor Detail

GridCacheClearAllRunnable

public GridCacheClearAllRunnable(GridCacheAdapter<K,V> cache,
                                 GridCacheVersion obsoleteVer,
                                 int id,
                                 int totalCnt,
                                 boolean readers)

Constructor.

Parameters:

cache - Cache to be cleared.

obsoleteVer - Obsolete version.

id - Mod for the given runnable.

totalCnt - Mods count across all spawned clearLocally runnables.

Method Detail

run

public void run()

Specified by:

run in interface Runnable

clearEntry

protected void clearEntry(GridCacheEntryEx e)

Clear entry from cache.

Parameters:

e - Entry.

owns

protected boolean owns(KeyCacheObject key)

Check whether this worker owns particular key.

Parameters:

key - Key.

Returns:

True in case this worker should process this key.

id

public int id()

Returns:

ID for the given runnable.

totalCount

public int totalCount()

Returns:

Total count across all spawned clearLocally runnables.

readers

public boolean readers()

Returns:

Whether to clean readers.

toString

public String toString()

Overrides:

toString in class Object