Module de.learnlib.oracle.parallelism

Package de.learnlib.oracle.parallelism

Class DynamicParallelAdaptiveOracle<I,O>

java.lang.Object

de.learnlib.oracle.parallelism.AbstractDynamicBatchProcessor<AdaptiveQuery<I,O>,AdaptiveMembershipOracle<I,O>>

de.learnlib.oracle.parallelism.DynamicParallelAdaptiveOracle<I,O>

Type Parameters:

I - input symbol type

O - output symbol type

All Implemented Interfaces:

AdaptiveMembershipOracle<I,O>, BatchProcessor<AdaptiveQuery<I,O>>, ParallelAdaptiveOracle<I,O>, ThreadPool

public class DynamicParallelAdaptiveOracle<I,O>
extends AbstractDynamicBatchProcessor<AdaptiveQuery<I,O>,AdaptiveMembershipOracle<I,O>>
implements ParallelAdaptiveOracle<I,O>

A specialized AbstractDynamicBatchProcessor for AdaptiveMembershipOracles that implements ParallelAdaptiveOracle.

Nested Class Summary

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

ThreadPool.PoolPolicy

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	processQueries(Collection<? extends AdaptiveQuery<I,O>> 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.AdaptiveMembershipOracle

processBatch, processQuery

Methods inherited from interface de.learnlib.oracle.ThreadPool

shutdown, shutdownNow

Constructor Detail

DynamicParallelAdaptiveOracle

public DynamicParallelAdaptiveOracle(Supplier<? extends AdaptiveMembershipOracle<I,O>> oracleSupplier,
                                     @org.checkerframework.checker.index.qual.NonNegative int batchSize,
                                     ExecutorService executor)

Method Detail

processQueries

public void processQueries(Collection<? extends AdaptiveQuery<I,O>> queries)

Description copied from interface: AdaptiveMembershipOracle

Processes the specified collection of queries. When this method returns, the provided inputs of the AdaptiveQuery.getInput() method will have been evaluated on the system under learning and its responses will have been forwarded to the AdaptiveQuery.processOutput(Object) method until the method has returned AdaptiveQuery.Response.FINISHED.

Specified by:

processQueries in interface AdaptiveMembershipOracle<I,O>

Parameters:

queries - the queries to process