VariantAccumulatorExecutor<A,R>
public static class VariantAccumulatorExecutor.MultiThreadedChunkBased<A extends VariantProcessor.Accumulator<R>,R> extends 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 | Description |
---|---|
MultiThreadedChunkBased(int numThreads,
VariantIteratorProducer vcIteratorProducer,
VariantProcessor.AccumulatorGenerator<A,R> accumulatorGenerator) |
Modifier and Type | Method | Description |
---|---|---|
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 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 InterruptedException
VariantAccumulatorExecutor
awaitCompletion
in interface VariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,R>
InterruptedException