Package picard.vcf.processor
Class VariantAccumulatorExecutor.MultiThreadedChunkBased<A extends VariantProcessor.Accumulator<R>,R>
java.lang.Object
picard.vcf.processor.VariantAccumulatorExecutor.MultiThreadedChunkBased<A,R>
- All Implemented Interfaces:
VariantAccumulatorExecutor<A,
R>
- Enclosing interface:
VariantAccumulatorExecutor<ACCUMULATOR extends VariantProcessor.Accumulator<RESULT>,
RESULT>
public static class VariantAccumulatorExecutor.MultiThreadedChunkBased<A extends VariantProcessor.Accumulator<R>,R>
extends Object
implements VariantAccumulatorExecutor<A,R>
A
VariantAccumulatorExecutor
that breaks down work into chunks described by the provided VariantIteratorProducer
and
spreads them over the indicated number of threads.-
Nested Class Summary
Nested classes/interfaces inherited from interface picard.vcf.processor.VariantAccumulatorExecutor
VariantAccumulatorExecutor.MultiThreadedChunkBased<A extends VariantProcessor.Accumulator<R>,
R> -
Constructor Summary
ConstructorsConstructorDescriptionMultiThreadedChunkBased
(int numThreads, VariantIteratorProducer vcIteratorProducer, VariantProcessor.AccumulatorGenerator<A, R> accumulatorGenerator) -
Method Summary
Modifier and TypeMethodDescriptionReturns theVariantProcessor.Accumulator
s associated with this executor.void
Blocks until the work is complete.void
start()
Starts the work of the executor, returning immediately.
-
Constructor Details
-
MultiThreadedChunkBased
public MultiThreadedChunkBased(int numThreads, VariantIteratorProducer vcIteratorProducer, VariantProcessor.AccumulatorGenerator<A, R> accumulatorGenerator)
-
-
Method Details
-
start
public void start()Description copied from interface:VariantAccumulatorExecutor
Starts the work of the executor, returning immediately.- Specified by:
start
in interfaceVariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,
R>
-
accumulators
Description copied from interface:VariantAccumulatorExecutor
Returns theVariantProcessor.Accumulator
s associated with this executor.- Specified by:
accumulators
in interfaceVariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,
R>
-
awaitCompletion
Description copied from interface:VariantAccumulatorExecutor
Blocks until the work is complete.- Specified by:
awaitCompletion
in interfaceVariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,
R> - Throws:
InterruptedException
-