com.hazelcast.util.scheduler

Class EntryTaskSchedulerFactory

java.lang.Object

com.hazelcast.util.scheduler.EntryTaskSchedulerFactory

public final class EntryTaskSchedulerFactory
extends Object

Factory for EntryTaskSchedulers.

Method Summary

Modifier and Type	Method and Description
static <K,V> EntryTaskScheduler<K,V>	newScheduler(TaskScheduler taskScheduler, ScheduledEntryProcessor<K,V> entryProcessor, ScheduleType scheduleType) Creates a new EntryTaskScheduler that will run all second operations in bulk.

Methods inherited from class java.lang.Object

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

Method Detail

newScheduler

public static <K,V> EntryTaskScheduler<K,V> newScheduler(TaskScheduler taskScheduler,
                                                         ScheduledEntryProcessor<K,V> entryProcessor,
                                                         ScheduleType scheduleType)

Creates a new EntryTaskScheduler that will run all second operations in bulk. Imagine a write-behind map where dirty entries will be stored in bulk. Note that each key can only occur once; meaning you cannot delay the execution. For example, once an entry is marked as dirty, it will run in write-delay-seconds, even if the entry is updated again within write-delay-seconds. Two things to remember: 1. A key cannot be re-scheduled (postponing its execution). 2. All entries scheduled for a given second will be executed once by your SecondBulkExecutor implementation. Once a key is executed, it can be re-scheduled for another execution.

EntryTaskScheduler implementation is thread-safe.

Parameters:

taskScheduler - ScheduledExecutorService instance to execute the second

entryProcessor - bulk processor

Returns:

EntryTaskScheduler that will run all second operations in bulk