com.nt.udc.util.state

Class StateSaverQueue

java.lang.Object

com.nt.udc.util.state.StateSaverQueue

All Implemented Interfaces:

java.lang.Runnable

public class StateSaverQueue
extends java.lang.Object
implements java.lang.Runnable

This class implements a asynchronous state saving thread, and a manager of state save requests. The class spins in its own thread, processing requests that are queued up. If no requests exist, it will go back to sleep, and then check later. This happens until the class is shutdown.

Constructor Summary

Constructors

Constructor and Description
StateSaverQueue(IntegerCallback saveFinishedCallback, LoggerIfc logger, java.lang.Object stateLock, TimedStateMerger stateMerger, StateFreezer stateFreezer, AsynchronousStateSaver stateSaver) Constructs a StateSaverThread.

Method Summary

Methods

Modifier and Type	Method and Description
void	addStateRequest(Callback requestor) Adds a save state request to the queue.
void	run() Run method for the state saving Thread.
void	shutdown() Stops the state saving Thread.

Methods inherited from class java.lang.Object

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

Constructor Detail

StateSaverQueue

public StateSaverQueue(IntegerCallback saveFinishedCallback,
               LoggerIfc logger,
               java.lang.Object stateLock,
               TimedStateMerger stateMerger,
               StateFreezer stateFreezer,
               AsynchronousStateSaver stateSaver)

Constructs a StateSaverThread.

Parameters:

saveFinishedCallback - Callback to an Object when all save state processing has finished, and normal processing has resumed. The number of processed requests is returned to the callback.

logger - Logger for errors and warnings.

stateLock - Insures no 2 save state routines occur at the same time.

stateMerger - Used to notify that a new state has been created, and merging should be done.

stateFreezer - Used to freeze the processing in the system.

stateSaver - Used for the actual save state routines.

Method Detail

shutdown

public void shutdown()

Stops the state saving Thread.

addStateRequest

public void addStateRequest(Callback requestor)

Adds a save state request to the queue.

Parameters:

requestor - Callback to the Object that initiated the save state request. This callback is made when the state has been save successfully, but before the system has resumed processing.

run

public void run()

Run method for the state saving Thread.

Specified by:

run in interface java.lang.Runnable