Module de.learnlib.oracle.parallelism

Package de.learnlib.oracle.parallelism

Class StaticParallelAdaptiveOracle<I,O>

java.lang.Object

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

de.learnlib.oracle.parallelism.StaticParallelAdaptiveOracle<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 StaticParallelAdaptiveOracle<I,O>
extends AbstractStaticBatchProcessor<AdaptiveQuery<I,O>,AdaptiveMembershipOracle<I,O>>
implements ParallelAdaptiveOracle<I,O>

A specialized AbstractStaticBatchProcessor 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
StaticParallelAdaptiveOracle(Collection<? extends AdaptiveMembershipOracle<I,O>> oracles, @org.checkerframework.checker.index.qual.NonNegative int minBatchSize, ExecutorService executorService)

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.AbstractStaticBatchProcessor

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

StaticParallelAdaptiveOracle

public StaticParallelAdaptiveOracle(Collection<? extends AdaptiveMembershipOracle<I,O>> oracles,
                                    @org.checkerframework.checker.index.qual.NonNegative int minBatchSize,
                                    ExecutorService executorService)

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