Class LockEvictionProcessor

  extended by com.hazelcast.concurrent.lock.LockEvictionProcessor
All Implemented Interfaces:

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

Constructor Summary
LockEvictionProcessor(NodeEngine nodeEngine, ObjectNamespace namespace)
Method Summary
 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


public LockEvictionProcessor(NodeEngine nodeEngine,
                             ObjectNamespace namespace)
Method Detail


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.