picard.util

Class AsyncIterator<T>

java.lang.Object

picard.util.AsyncIterator<T>

All Implemented Interfaces:

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

public class AsyncIterator<T>
extends Object
implements CloseableIterator<T>

Wrapper around a CloseableIterator that reads in a separate thread, for cases in which that might be efficient.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_QUEUE_SIZE

Constructor Summary

Constructors

Constructor and Description
AsyncIterator(CloseableIterator<T> underlyingIterator, int queueSize, String threadNamePrefix)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Stops the thread and then calls synchronouslyClose() to allow implementation to do any one time clean up.
boolean	hasNext()
T	next()
void	remove()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_QUEUE_SIZE

public static final int DEFAULT_QUEUE_SIZE

See Also:

Constant Field Values

Constructor Detail

AsyncIterator

public AsyncIterator(CloseableIterator<T> underlyingIterator,
             int queueSize,
             String threadNamePrefix)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<T>

next

public T next()

Specified by:

next in interface Iterator<T>

remove

public void remove()

Specified by:

remove in interface Iterator<T>

close

public void close()

Stops the thread and then calls synchronouslyClose() to allow implementation to do any one time clean up.

Specified by:

close in interface CloseableIterator<T>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable