Package picard.util
Class AsyncIterator<T>
- java.lang.Object
-
- picard.util.AsyncIterator<T>
-
- All Implemented Interfaces:
htsjdk.samtools.util.CloseableIterator<T>,Closeable,AutoCloseable,Iterator<T>
public class AsyncIterator<T> extends Object implements htsjdk.samtools.util.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 Description static intDEFAULT_QUEUE_SIZE
-
Constructor Summary
Constructors Constructor Description AsyncIterator(htsjdk.samtools.util.CloseableIterator<T> underlyingIterator, int queueSize, String threadNamePrefix)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()Stops the thread and then calls synchronouslyClose() to allow implementation to do any one time clean up.booleanhasNext()Tnext()voidremove()-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.util.Iterator
forEachRemaining
-
-
-
-
Field Detail
-
DEFAULT_QUEUE_SIZE
public static final int DEFAULT_QUEUE_SIZE
- See Also:
- Constant Field Values
-
-
Method Detail
-
close
public void close()
Stops the thread and then calls synchronouslyClose() to allow implementation to do any one time clean up.- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfacehtsjdk.samtools.util.CloseableIterator<T>
-
-