com.bigdata.relation.accesspath

Class MultiplexBlockingBuffer<E>

java.lang.Object

com.bigdata.relation.accesspath.MultiplexBlockingBuffer<E>

public class MultiplexBlockingBuffer<E>
extends Object

A factory for skins which may be used to multiplex writes against a shared BlockingBuffer instance. Each skin writes through to the backing BlockingBuffer but may be closed independently of the backing BlockingBuffer. This allows multiple produces to share a single BlockingBuffer as long as they use a subset of the IBlockingBuffer API (they can not set the Future on the objects returned by this factory or obtain its IBlockingBuffer.iterator(), but those operations can be performed against the shared IBlockingBuffer).

Version:

$Id: MultiplexBlockingBuffer.java 3830 2010-10-20 18:30:25Z thompsonbry $

Author:

Bryan Thompson

Constructor Summary

Constructors

Constructor and Description
MultiplexBlockingBuffer(IBlockingBuffer<E> b)

Method Summary

Methods

Modifier and Type	Method and Description
void	flushAndCloseAll()
IBlockingBuffer<E>	getBackingBuffer() The IBlockingBuffer reference provided to the constructor.
boolean	isOpen()
IBlockingBuffer<E>	newInstance() Create a new skin for the shared buffer, incrementing the count of the #of open skins that buffer.

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiplexBlockingBuffer

public MultiplexBlockingBuffer(IBlockingBuffer<E> b)

Method Detail

isOpen

public boolean isOpen()

newInstance

public IBlockingBuffer<E> newInstance()

Create a new skin for the shared buffer, incrementing the count of the #of open skins that buffer. The shared buffer will be closed atomically once all open skins have been closed.

flushAndCloseAll

public void flushAndCloseAll()

getBackingBuffer

public IBlockingBuffer<E> getBackingBuffer()

The IBlockingBuffer reference provided to the constructor.