Package com.tangosol.coherence.servlet
Class IncrementalReapTask
- java.lang.Object
-
- com.tangosol.coherence.servlet.AbstractReapTask
-
- com.tangosol.coherence.servlet.IncrementalReapTask
-
- All Implemented Interfaces:
Runnable
- Direct Known Subclasses:
SessionHelper.SessionReaperDaemon.IncrementalReapTask
public class IncrementalReapTask extends AbstractReapTask
A task that starts a reaping cycle and reaps session in sequence.
-
-
Field Summary
-
Fields inherited from class com.tangosol.coherence.servlet.AbstractReapTask
mQueueWaitTime, mStartTime
-
-
Constructor Summary
Constructors Constructor Description IncrementalReapTask(SessionHelper sessionHelper, SessionReaperStatistics statistics, Iterator iterIds, int cEstimatedSessions)
Construct an IncrementalReapTask.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getSessionChunkCount()
int
getSessionChunkMillis()
protected void
reap()
The task process: Process a portion of the reaping cycle.protected void
scheduleNextCycle()
Schedules the next reaping cycle.-
Methods inherited from class com.tangosol.coherence.servlet.AbstractReapTask
checkAndInvalidate, done, getDaemon, getNrOfInvalidatedSessions, getSessionHelper, getSessionIdIterator, isDone, logInvalidationExceptions, run
-
-
-
-
Constructor Detail
-
IncrementalReapTask
public IncrementalReapTask(SessionHelper sessionHelper, SessionReaperStatistics statistics, Iterator iterIds, int cEstimatedSessions)
Construct an IncrementalReapTask.- Parameters:
sessionHelper
- the session helperstatistics
- the session reaper statisticsiterIds
- an iterator of session IDs to checkcEstimatedSessions
- the estimated number of session IDs to check
-
-
Method Detail
-
reap
protected void reap()
The task process: Process a portion of the reaping cycle.- Specified by:
reap
in classAbstractReapTask
-
scheduleNextCycle
protected void scheduleNextCycle()
Description copied from class:AbstractReapTask
Schedules the next reaping cycle.- Overrides:
scheduleNextCycle
in classAbstractReapTask
-
getSessionChunkCount
public int getSessionChunkCount()
- Returns:
- the number of sessions to process at a time
-
getSessionChunkMillis
public int getSessionChunkMillis()
- Returns:
- the number of milliseconds allocated to each chunk
-
-