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>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LockEvictionProcessor
public LockEvictionProcessor(NodeEngine nodeEngine,
ObjectNamespace namespace)
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 it for a future time.
Imagine you are implementing this for a dirty records. If mapStore.storeAll
throws exception, you might want to reschedule the failed records.
- Specified by:
process
in interface ScheduledEntryProcessor<Data,Integer>
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.