htsjdk.variant.variantcontext.writer

Class AsyncVariantContextWriter

java.lang.Object

htsjdk.samtools.util.AbstractAsyncWriter<VariantContext>

htsjdk.variant.variantcontext.writer.AsyncVariantContextWriter

All Implemented Interfaces:

VariantContextWriter, java.io.Closeable, java.lang.AutoCloseable

public class AsyncVariantContextWriter
extends AbstractAsyncWriter<VariantContext>
implements VariantContextWriter

AsyncVariantContextWriter that can be wrapped around an underlying AsyncVariantContextWriter to provide asynchronous output. Records added are placed into a queue, the queue is then drained into the underlying VariantContextWriter by a thread owned by the instance. Exceptions experienced by the writer thread will be emitted back to the caller in subsequent calls to either add() or close().

Field Summary

Fields inherited from class htsjdk.samtools.util.AbstractAsyncWriter

DEFAULT_QUEUE_SIZE

Constructor Summary

Constructors

Constructor and Description
AsyncVariantContextWriter(VariantContextWriter out) Creates a new AsyncVariantContextWriter wrapping the provided VariantContextWriter.
AsyncVariantContextWriter(VariantContextWriter out, int queueSize) Creates an AsyncVariantContextWriter wrapping the provided VariantContextWriter and using the specified queue size for buffer VariantContexts.

Method Summary

Modifier and Type	Method and Description
void	add(VariantContext vc)
boolean	checkError()
protected java.lang.String	getThreadNamePrefix() Returns the prefix to use when naming threads.
protected void	synchronouslyClose()
protected void	synchronouslyWrite(VariantContext item)
void	writeHeader(VCFHeader header)

Methods inherited from class htsjdk.samtools.util.AbstractAsyncWriter

close, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface htsjdk.variant.variantcontext.writer.VariantContextWriter

close

Constructor Detail

AsyncVariantContextWriter

public AsyncVariantContextWriter(VariantContextWriter out)

Creates a new AsyncVariantContextWriter wrapping the provided VariantContextWriter.

AsyncVariantContextWriter

public AsyncVariantContextWriter(VariantContextWriter out,
                                 int queueSize)

Creates an AsyncVariantContextWriter wrapping the provided VariantContextWriter and using the specified queue size for buffer VariantContexts.

Method Detail

synchronouslyWrite

protected void synchronouslyWrite(VariantContext item)

Specified by:

synchronouslyWrite in class AbstractAsyncWriter<VariantContext>

synchronouslyClose

protected void synchronouslyClose()

Specified by:

synchronouslyClose in class AbstractAsyncWriter<VariantContext>

getThreadNamePrefix

protected final java.lang.String getThreadNamePrefix()

Description copied from class: AbstractAsyncWriter

Returns the prefix to use when naming threads.

Specified by:

getThreadNamePrefix in class AbstractAsyncWriter<VariantContext>

add

public void add(VariantContext vc)

Specified by:

add in interface VariantContextWriter

writeHeader

public void writeHeader(VCFHeader header)

Specified by:

writeHeader in interface VariantContextWriter

checkError

public boolean checkError()

Specified by:

checkError in interface VariantContextWriter

Returns:

true if the underlying stream is a java.io.PrintStream and its checkError returned true, used for pipelines