Package de.learnlib.oracle.parallelism
Class AbstractDynamicBatchProcessor<Q,P extends BatchProcessor<Q>>
- java.lang.Object
-
- de.learnlib.oracle.parallelism.AbstractDynamicBatchProcessor<Q,P>
-
- Type Parameters:
Q
- query typeP
- (sub-) processor type
- All Implemented Interfaces:
BatchProcessor<Q>
,ThreadPool
- Direct Known Subclasses:
DynamicParallelOmegaOracle
,DynamicParallelOracle
public abstract class AbstractDynamicBatchProcessor<Q,P extends BatchProcessor<Q>> extends Object implements ThreadPool, BatchProcessor<Q>
A batch processor that dynamically distributes queries to worker threads.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface de.learnlib.oracle.parallelism.ThreadPool
ThreadPool.PoolPolicy
-
-
Field Summary
Fields Modifier and Type Field Description static int
BATCH_SIZE
static ThreadPool.PoolPolicy
POOL_POLICY
static int
POOL_SIZE
-
Constructor Summary
Constructors Constructor Description AbstractDynamicBatchProcessor(Supplier<? extends P> oracleSupplier, @org.checkerframework.checker.index.qual.NonNegative int batchSize, ExecutorService executor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected P
getProcessor()
void
processBatch(Collection<? extends Q> queries)
void
shutdown()
void
shutdownNow()
-
-
-
Field Detail
-
BATCH_SIZE
public static final int BATCH_SIZE
-
POOL_SIZE
public static final int POOL_SIZE
-
POOL_POLICY
public static final ThreadPool.PoolPolicy POOL_POLICY
-
-
Constructor Detail
-
AbstractDynamicBatchProcessor
public AbstractDynamicBatchProcessor(Supplier<? extends P> oracleSupplier, @org.checkerframework.checker.index.qual.NonNegative int batchSize, ExecutorService executor)
-
-
Method Detail
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceThreadPool
-
shutdownNow
public void shutdownNow()
- Specified by:
shutdownNow
in interfaceThreadPool
-
processBatch
public void processBatch(Collection<? extends Q> queries)
- Specified by:
processBatch
in interfaceBatchProcessor<Q>
-
getProcessor
protected P getProcessor()
-
-