com.hazelcast.concurrent.lock

Class LockEvictionProcessor

java.lang.Object

com.hazelcast.concurrent.lock.LockEvictionProcessor

All Implemented Interfaces:

ScheduledEntryProcessor<Data,Integer>

public final class LockEvictionProcessor
extends Object
implements ScheduledEntryProcessor<Data,Integer>

Constructor Summary

Constructors

Constructor and Description
LockEvictionProcessor(NodeEngine nodeEngine, ObjectNamespace namespace)

Method Summary

Modifier and Type	Method and Description
void	process(EntryTaskScheduler<Data,Integer> scheduler, Collection<ScheduledEntry<Data,Integer>> entries) Processes all entries.

Methods inherited from class java.lang.Object

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

Constructor Detail

LockEvictionProcessor

public LockEvictionProcessor(NodeEngine nodeEngine,
                             ObjectNamespace namespace)

Method Detail

process

public void process(EntryTaskScheduler<Data,Integer> scheduler,
                    Collection<ScheduledEntry<Data,Integer>> entries)

Description copied from interface: ScheduledEntryProcessor

Processes all entries. Implementation has to handle the failures and can possibly reschedule for a future time. Imagine you are implementing this for dirty records: if mapStore.storeAll throws an exception, you might want to reschedule the failed records.

Specified by:

process in interface ScheduledEntryProcessor<Data,Integer>

Parameters:

scheduler - the EntryTaskScheduler

entries - the entries (key and value) to process