org.epics.pvmanager

Class CacheCollector<T>

java.lang.Object

org.epics.pvmanager.CacheCollector<T>

Type Parameters:

T - the type contained in the cache

All Implemented Interfaces:

Collector<T,List<T>>, ReadFunction<List<T>>, WriteFunction<T>

public class CacheCollector<T>
extends Object
implements Collector<T,List<T>>

Collects value at read rate and keeps the last n.

The values are returned oldest value first. When maxSize is reached, the oldest values are discarded.

Author:

carcassi

Constructor Summary

Constructors

Constructor and Description
CacheCollector(int maxSize) A new cache collector with max size for the cache.

Method Summary

Methods

Modifier and Type	Method and Description
int	getMaxSize() The maximum number of elements in the cache.
List<T>	readValue() Calculates, if needed, and then returns the value for this function.
void	setChangeNotification(Runnable notification) Task to run to notify of the presence of a new value in the collector.
void	setMaxSize(int maxSize) Changes the maximum size of the cache.
void	writeValue(T newValue) Takes the value and consumes it.

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheCollector

public CacheCollector(int maxSize)

A new cache collector with max size for the cache.

Parameters:

maxSize - maximum number of elements in the cache

Method Detail

setChangeNotification

public void setChangeNotification(Runnable notification)

Description copied from interface: Collector

Task to run to notify of the presence of a new value in the collector.

Specified by:

setChangeNotification in interface Collector<T,List<T>>

writeValue

public void writeValue(T newValue)

Description copied from interface: WriteFunction

Takes the value and consumes it.

Specified by:

writeValue in interface WriteFunction<T>

Parameters:

newValue - a value

readValue

public List<T> readValue()

Description copied from interface: ReadFunction

Calculates, if needed, and then returns the value for this function.

Specified by:

readValue in interface ReadFunction<List<T>>

Returns:

a value

setMaxSize

public void setMaxSize(int maxSize)

Changes the maximum size of the cache.

If new maxSize is less than the current number of element in the cache, the old values are discarded.

Parameters:

maxSize - the maximum number of elements in the cache.

getMaxSize

public int getMaxSize()

The maximum number of elements in the cache.

Returns:

the maximum number of elements in the cache