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 type

P - (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.

Author:

Malte Isberner

Nested Class Summary

Nested classes/interfaces inherited from interface de.learnlib.api.oracle.parallelism.ThreadPool

ThreadPool.PoolPolicy

Field Summary

Fields

Modifier and Type	Field and Description
static int	BATCH_SIZE
static ThreadPool.PoolPolicy	POOL_POLICY
static int	POOL_SIZE

Constructor Summary

Constructors

Constructor and Description
AbstractDynamicBatchProcessor(Supplier<? extends P> oracleSupplier, @NonNegative int batchSize, ExecutorService executor)

Method Summary

Modifier and Type	Method and Description
protected P	getProcessor()
void	processBatch(Collection<? extends Q> queries) Process the batch.
void	shutdown() Shuts down all worker threads, but waits for any queued queries to be processed.
void	shutdownNow() Shuts down all worker threads, and attempts to abort any query processing currently taking place.

Methods inherited from class java.lang.Object

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

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,
                                     @NonNegative int batchSize,
                                     ExecutorService executor)

Method Detail

shutdown

public void shutdown()

Description copied from interface: ThreadPool

Shuts down all worker threads, but waits for any queued queries to be processed.

Specified by:

shutdown in interface ThreadPool

See Also:

ExecutorService.shutdown()

shutdownNow

public void shutdownNow()

Description copied from interface: ThreadPool

Shuts down all worker threads, and attempts to abort any query processing currently taking place.

Specified by:

shutdownNow in interface ThreadPool

See Also:

ExecutorService.shutdownNow()

processBatch

public void processBatch(Collection<? extends Q> queries)

Description copied from interface: BatchProcessor

Process the batch.

Specified by:

processBatch in interface BatchProcessor<Q>

Parameters:

queries - the batch to process

getProcessor

protected P getProcessor()