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 int
DEFAULT_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 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
-
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:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfacehtsjdk.samtools.util.CloseableIterator<T>
-
-