broadwick.stochastic

Class StochasticSimulator.ThetaQueue

java.lang.Object

broadwick.stochastic.StochasticSimulator.ThetaQueue

Enclosing class:

StochasticSimulator

private class StochasticSimulator.ThetaQueue
extends Object

Manages the registered theta events. Each registered theta event is stored in a table containing the time of the event the list of observers for that event and the list of events for that time.

Field Summary

Fields

Modifier and Type	Field and Description
private double	nextThetaEventTime
private com.google.common.collect.Table<Double,Observer,Collection<Object>>	thetas

Constructor Summary

Constructors

Constructor and Description
ThetaQueue() Construct an empty theta queue.

Method Summary

Modifier and Type	Method and Description
Map<Observer,Collection<Object>>	getNextEventDataAndRemove() Get the next observer and the collection of events they are subscribed to and remove it from the theta queue.
void	pushTheta(double time, Observer obs, Object theta) Add a new theta event to the registry, including the time, collection of observers and collection of events.

Methods inherited from class java.lang.Object

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

Field Detail

thetas

private final com.google.common.collect.Table<Double,Observer,Collection<Object>> thetas

nextThetaEventTime

private double nextThetaEventTime

Constructor Detail

ThetaQueue

public ThetaQueue()

Construct an empty theta queue.

Method Detail

pushTheta

public void pushTheta(double time,
                      Observer obs,
                      Object theta)

Add a new theta event to the registry, including the time, collection of observers and collection of events. Each event is stored as an object where it is assumed that the observer

Parameters:

time - the time the theta event occurs.

obs - the observers.

theta - the theta event.

getNextEventDataAndRemove

public Map<Observer,Collection<Object>> getNextEventDataAndRemove()

Get the next observer and the collection of events they are subscribed to and remove it from the theta queue.

Returns:

a map of the observers and their subscribed data.