Class ArrayBlockingStream<T>

java.lang.Object

fr.inria.rules.integraal.util.stream.AbstractCloseableIterator<T>

fr.inria.rules.integraal.util.stream.ArrayBlockingStream<T>

Type Parameters:

T - type of the elements

All Implemented Interfaces:

CloseableIterator<T>, CloseableIteratorWithoutException<T>, InMemoryStream<T>, Closeable, AutoCloseable, Iterator<T>

public class ArrayBlockingStream<T>
extends AbstractCloseableIterator<T>
implements InMemoryStream<T>

Concurrent structure for read/write in a set.

Author:

Florent Tornil

Constructor Summary

Constructors

Constructor	Description
ArrayBlockingStream(int bufferSize)	Creates an array-backed blocking stream.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the iterator and releases its resources.
boolean	hasNext()	Indicates whether another element is available, blocking while the stream remains open and empty.
T	next()	Returns the next element from the iterator.
void	write(Iterator<T> it)	Writes every object from the supplied iterator into the in-memory stream.
void	write(T object)	Writes one object into the stream, blocking while the buffer is full.

Methods inherited from class AbstractCloseableIterator

finalize

Methods inherited from class Object

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

Methods inherited from interface Iterator

forEachRemaining, remove

Constructor Details

ArrayBlockingStream

public ArrayBlockingStream(int bufferSize)

Creates an array-backed blocking stream.

Parameters:

bufferSize - size of the buffer

Method Details

write

public void write(T object)

Writes one object into the stream, blocking while the buffer is full.

Specified by:

write in interface InMemoryStream<T>

Parameters:

object - the object to write

hasNext

public boolean hasNext()

Indicates whether another element is available, blocking while the stream remains open and empty.

Specified by:

hasNext in interface CloseableIterator<T>

Specified by:

hasNext in interface CloseableIteratorWithoutException<T>

Specified by:

hasNext in interface Iterator<T>

Returns:

true if another element can be read

next

public T next()

Description copied from interface: CloseableIterator

Returns the next element from the iterator.

Specified by:

next in interface CloseableIterator<T>

Specified by:

next in interface CloseableIteratorWithoutException<T>

Specified by:

next in interface Iterator<T>

Returns:

the next element

close

public void close()

Description copied from interface: CloseableIterator

Closes the iterator and releases its resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface CloseableIterator<T>

write

public void write(Iterator<T> it)

Description copied from interface: InMemoryStream

Writes every object from the supplied iterator into the in-memory stream.

Specified by:

write in interface InMemoryStream<T>

Parameters:

it - objects to write