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 and Description
IncrementalReapTask(SessionHelper sessionHelper, SessionReaperStatistics statistics, Iterator iterIds, int cEstimatedSessions) Construct an IncrementalReapTask.

Method Summary

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

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

Constructor Detail

IncrementalReapTask

public IncrementalReapTask(SessionHelper sessionHelper,
                           SessionReaperStatistics statistics,
                           Iterator iterIds,
                           int cEstimatedSessions)

Construct an IncrementalReapTask.

Parameters:

sessionHelper - the session helper

statistics - the session reaper statistics

iterIds - an iterator of session IDs to check

cEstimatedSessions - 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 class AbstractReapTask

scheduleNextCycle

protected void scheduleNextCycle()

Description copied from class: AbstractReapTask

Schedules the next reaping cycle.

Overrides:

scheduleNextCycle in class AbstractReapTask

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