Package de.learnlib.oracle.parallelism

Class AbstractDynamicBatchProcessorBuilder<Q,P extends BatchProcessor<Q>,OR>

java.lang.Object

de.learnlib.oracle.parallelism.AbstractDynamicBatchProcessorBuilder<Q,P,OR>

Type Parameters:

Q - query type

P - (sub-) processor type

OR - constructed oracle type

Direct Known Subclasses:

DynamicParallelOmegaOracleBuilder, DynamicParallelOracleBuilder

public abstract class AbstractDynamicBatchProcessorBuilder<Q,P extends BatchProcessor<Q>,OR>
extends Object

Builder class for a AbstractDynamicBatchProcessor.

Constructor Summary

Constructors

Constructor	Description
AbstractDynamicBatchProcessorBuilder(Collection<? extends P> oracles)
AbstractDynamicBatchProcessorBuilder(Supplier<? extends P> oracleSupplier)

Method Summary

Modifier and Type	Method	Description
protected abstract OR	buildOracle(Supplier<? extends P> supplier, int batchSize, ExecutorService executorService)
OR	create()
AbstractDynamicBatchProcessorBuilder<Q,P,OR>	withBatchSize(int batchSize)
AbstractDynamicBatchProcessorBuilder<Q,P,OR>	withCustomExecutor(ExecutorService executor)
AbstractDynamicBatchProcessorBuilder<Q,P,OR>	withPoolPolicy(ThreadPool.PoolPolicy policy)
AbstractDynamicBatchProcessorBuilder<Q,P,OR>	withPoolSize(@org.checkerframework.checker.index.qual.NonNegative int poolSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractDynamicBatchProcessorBuilder

public AbstractDynamicBatchProcessorBuilder(Supplier<? extends P> oracleSupplier)

AbstractDynamicBatchProcessorBuilder

public AbstractDynamicBatchProcessorBuilder(Collection<? extends P> oracles)

Method Detail

withCustomExecutor

public AbstractDynamicBatchProcessorBuilder<Q,P,OR> withCustomExecutor(ExecutorService executor)

withBatchSize

public AbstractDynamicBatchProcessorBuilder<Q,P,OR> withBatchSize(int batchSize)

withPoolSize

public AbstractDynamicBatchProcessorBuilder<Q,P,OR> withPoolSize(@org.checkerframework.checker.index.qual.NonNegative int poolSize)

withPoolPolicy

public AbstractDynamicBatchProcessorBuilder<Q,P,OR> withPoolPolicy(ThreadPool.PoolPolicy policy)

create

public OR create()

buildOracle

protected abstract OR buildOracle(Supplier<? extends P> supplier,
                                  int batchSize,
                                  ExecutorService executorService)