Package de.learnlib.oracle.parallelism

Class DynamicParallelOracle<I,D>

java.lang.Object

de.learnlib.oracle.parallelism.AbstractDynamicBatchProcessor<Query<I,D>,MembershipOracle<I,D>>

de.learnlib.oracle.parallelism.DynamicParallelOracle<I,D>

Type Parameters:

I - input symbol type

D - output domain type

All Implemented Interfaces:

MembershipOracle<I,D>, BatchProcessor<Query<I,D>>, ParallelOracle<I,D>, ThreadPool, QueryAnswerer<I,D>

public class DynamicParallelOracle<I,D>
extends AbstractDynamicBatchProcessor<Query<I,D>,MembershipOracle<I,D>>
implements ParallelOracle<I,D>

A specialized AbstractDynamicBatchProcessor for MembershipOracles that implements ParallelOracle.

Nested Class Summary

Nested classes/interfaces inherited from interface de.learnlib.oracle.MembershipOracle

MembershipOracle.DFAMembershipOracle<I>, MembershipOracle.MealyMembershipOracle<I,O>, MembershipOracle.MooreMembershipOracle<I,O>

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

ThreadPool.PoolPolicy

Field Summary

Fields inherited from class de.learnlib.oracle.parallelism.AbstractDynamicBatchProcessor

BATCH_SIZE, POOL_POLICY, POOL_SIZE

Constructor Summary

Constructors

Constructor	Description
DynamicParallelOracle(Supplier<? extends MembershipOracle<I,D>> oracleSupplier, @org.checkerframework.checker.index.qual.NonNegative int batchSize, ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
void	processQueries(Collection<? extends Query<I,D>> queries)	Processes the specified collection of queries.

Methods inherited from class de.learnlib.oracle.parallelism.AbstractDynamicBatchProcessor

getProcessor, processBatch, shutdown, shutdownNow

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.learnlib.oracle.MembershipOracle

answerQuery, answerQuery, asOracle, processBatch, processQuery

Methods inherited from interface de.learnlib.oracle.parallelism.ThreadPool

shutdown, shutdownNow

Constructor Detail

DynamicParallelOracle

public DynamicParallelOracle(Supplier<? extends MembershipOracle<I,D>> oracleSupplier,
                             @org.checkerframework.checker.index.qual.NonNegative int batchSize,
                             ExecutorService executor)

Method Detail

processQueries

public void processQueries(Collection<? extends Query<I,D>> queries)

Description copied from interface: MembershipOracle

Processes the specified collection of queries. When this method returns, each of the contained queries Query.answer(Object) method should have been called with an argument reflecting the SUL response to the respective query.

Specified by:

processQueries in interface MembershipOracle<I,D>

Parameters:

queries - the queries to process

See Also:

Query.answer(Object)