Package picard.util

Class 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.
    • Constructor Detail

      • AsyncIterator

        public AsyncIterator​(htsjdk.samtools.util.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 AutoCloseable
        Specified by:
        close in interface Closeable
        Specified by:
        close in interface htsjdk.samtools.util.CloseableIterator<T>