cern.laser.util.buffer

Class SynchroBufferAdapter

java.lang.Object

cern.laser.util.buffer.SynchroBufferAdapter

public class SynchroBufferAdapter
extends java.lang.Object

A buffering utility class. It is an adapter for a SynchroBuffer instance allowing to detach the buffer consumer thread from the SynchroBuffer itself for slow consumers.

Author:

F.Calderini

Constructor Summary

Constructors

Constructor and Description
SynchroBufferAdapter(SynchroBufferListener listener, SynchroBuffer buffer) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close() Close the buffer and deallocate resources.
void	disable() Disable the listener.
void	enable() Enable the listener.
void	push(java.util.Collection collection) Push a collection of objects into the buffer.
void	push(java.lang.Object object) Push an object into the buffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchroBufferAdapter

public SynchroBufferAdapter(SynchroBufferListener listener,
                            SynchroBuffer buffer)

Constructor. The listener is disabled by default.

Parameters:

listener - the buffer listener

buffer - the SynchroBuffer instance

Method Detail

push

public void push(java.lang.Object object)

Push an object into the buffer.

Parameters:

object - the object to push

push

public void push(java.util.Collection collection)

Push a collection of objects into the buffer.

Parameters:

collection - the collection of objects to push

enable

public void enable()

Enable the listener. The listener is disabled by default.

disable

public void disable()

Disable the listener. Pushed object are kept in the buffer and delivered when the listener is enabled.

close

public void close()

Close the buffer and deallocate resources.