public static class VariantAccumulatorExecutor.MultiThreadedChunkBased<A extends VariantProcessor.Accumulator<R>,R> extends java.lang.Object implements VariantAccumulatorExecutor<A,R>
VariantAccumulatorExecutor
that breaks down work into chunks described by the provided VariantIteratorProducer
and
spreads them over the indicated number of threads.VariantAccumulatorExecutor.MultiThreadedChunkBased<A extends VariantProcessor.Accumulator<R>,R>
Constructor and Description |
---|
MultiThreadedChunkBased(int numThreads,
VariantIteratorProducer vcIteratorProducer,
VariantProcessor.AccumulatorGenerator<A,R> accumulatorGenerator) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<A> |
accumulators()
Returns the
VariantProcessor.Accumulator s associated with this executor. |
void |
awaitCompletion()
Blocks until the work is complete.
|
void |
start()
Starts the work of the executor, returning immediately.
|
public MultiThreadedChunkBased(int numThreads, VariantIteratorProducer vcIteratorProducer, VariantProcessor.AccumulatorGenerator<A,R> accumulatorGenerator)
public void start()
VariantAccumulatorExecutor
start
in interface VariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,R>
public java.util.Collection<A> accumulators()
VariantAccumulatorExecutor
VariantProcessor.Accumulator
s associated with this executor.accumulators
in interface VariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,R>
public void awaitCompletion() throws java.lang.InterruptedException
VariantAccumulatorExecutor
awaitCompletion
in interface VariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,R>
java.lang.InterruptedException