org.diirt.datasource.expression

Class Queue<T>

java.lang.Object

org.diirt.datasource.expression.DesiredRateExpressionListImpl<R>

org.diirt.datasource.expression.DesiredRateExpressionImpl<List<T>>

org.diirt.datasource.expression.Queue<T>

Type Parameters:

T - the type of values in the queue

All Implemented Interfaces:

DesiredRateExpression<List<T>>, DesiredRateExpressionList<List<T>>

public class Queue<T>
extends DesiredRateExpressionImpl<List<T>>

A queue expression.

The expression can be used to collect values from pvmanager datasources or from external sources.

Author:

carcassi

Constructor Summary

Constructors

Constructor and Description
Queue(int maxSize) Creates a new queue expression.
Queue(SourceRateExpression<T> sourceExpression, int maxSize) Creates a new queue expression.

Method Summary

Modifier and Type	Method and Description
void	add(T newValue) Adds a new value to the queue
WriteFunction<T>	getWriteFunction() The write function to be used to fill the queue.
Queue<T>	maxSize(int maxSize) Changes the maximum size of the queue.

Methods inherited from class org.diirt.datasource.expression.DesiredRateExpressionImpl

as, fillReadRecipe, getDesiredRateExpressionImpl, getFunction, getName

Methods inherited from class org.diirt.datasource.expression.DesiredRateExpressionListImpl

and, getDesiredRateExpressions

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.diirt.datasource.expression.DesiredRateExpressionList

and, getDesiredRateExpressions

Constructor Detail

Queue

public Queue(int maxSize)

Creates a new queue expression.

Parameters:

maxSize - the maximum number of elements in the cache

Queue

public Queue(SourceRateExpression<T> sourceExpression,
             int maxSize)

Creates a new queue expression.

Parameters:

sourceExpression - the source rate expression that will fill the queue

maxSize - the maximum number of elements in the cache

Method Detail

getWriteFunction

public WriteFunction<T> getWriteFunction()

The write function to be used to fill the queue.

Returns:

a write function

maxSize

public Queue<T> maxSize(int maxSize)

Changes the maximum size of the queue.

Parameters:

maxSize - the number of values kept in the queue

Returns:

this expression

add

public void add(T newValue)

Adds a new value to the queue

Parameters:

newValue - the new value