Public Member Functions | |
SynchroBufferAdapter (SynchroBufferListener listener, SynchroBuffer buffer) | |
void | push (Object object) |
void | push (Collection collection) |
void | enable () |
void | disable () |
void | close () |
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.
cern.laser.util.buffer.SynchroBufferAdapter.SynchroBufferAdapter | ( | SynchroBufferListener | listener, | |
SynchroBuffer | buffer | |||
) |
Constructor. The listener is disabled by default.
listener | the buffer listener | |
buffer | the SynchroBuffer instance |
References cern.laser.util.buffer.SynchroBuffer.setSynchroBufferListener().
void cern.laser.util.buffer.SynchroBufferAdapter.close | ( | ) |
Close the buffer and deallocate resources.
References cern.laser.util.buffer.SynchroBuffer.close().
void cern.laser.util.buffer.SynchroBufferAdapter.disable | ( | ) |
Disable the listener. Pushed object are kept in the buffer and delivered when the listener is enabled.
References cern.laser.util.buffer.SynchroBuffer.disable().
void cern.laser.util.buffer.SynchroBufferAdapter.enable | ( | ) |
Enable the listener. The listener is disabled by default.
References cern.laser.util.buffer.SynchroBuffer.enable().
void cern.laser.util.buffer.SynchroBufferAdapter.push | ( | Object | object | ) |
Push an object into the buffer.
object | the object to push |
References cern.laser.util.buffer.SynchroBuffer.push().
void cern.laser.util.buffer.SynchroBufferAdapter.push | ( | Collection | collection | ) |
Push a collection of objects into the buffer.
collection | the collection of objects to push |
References cern.laser.util.buffer.SynchroBuffer.push().