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.Accumulators 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()
VariantAccumulatorExecutorstart in interface VariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,R>public Collection<A> accumulators()
VariantAccumulatorExecutorVariantProcessor.Accumulators associated with this executor.accumulators in interface VariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,R>public void awaitCompletion()
throws InterruptedException
VariantAccumulatorExecutorawaitCompletion in interface VariantAccumulatorExecutor<A extends VariantProcessor.Accumulator<R>,R>InterruptedException