Package de.learnlib.oracle.parallelism

Class DynamicParallelOmegaOracle<S,I,D>

java.lang.Object

de.learnlib.oracle.parallelism.AbstractDynamicBatchProcessor<OmegaQuery<I,D>,OmegaMembershipOracle<S,I,D>>

de.learnlib.oracle.parallelism.DynamicParallelOmegaOracle<S,I,D>

Type Parameters:

I - input symbol type

D - output domain type

All Implemented Interfaces:

OmegaMembershipOracle<S,I,D>, OmegaQueryAnswerer<S,I,D>, BatchProcessor<OmegaQuery<I,D>>, ParallelOmegaOracle<S,I,D>, ThreadPool

public class DynamicParallelOmegaOracle<S,I,D>
extends AbstractDynamicBatchProcessor<OmegaQuery<I,D>,OmegaMembershipOracle<S,I,D>>
implements ParallelOmegaOracle<S,I,D>

A specialized AbstractDynamicBatchProcessor for OmegaMembershipOracles that implements ParallelOmegaOracle.

Nested Class Summary

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

OmegaMembershipOracle.DFAOmegaMembershipOracle<S,I>, OmegaMembershipOracle.MealyOmegaMembershipOracle<S,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
DynamicParallelOmegaOracle(Supplier<? extends OmegaMembershipOracle<S,I,D>> oracleSupplier, @org.checkerframework.checker.index.qual.NonNegative int batchSize, ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
MembershipOracle<I,D>	getMembershipOracle()	Returns a regular membership oracle.
boolean	isSameState(Word<I> w1, S s1, Word<I> w2, S s2)	Returns whether two states are equal, or if both access sequences w1, and w2 end up in the same state.
void	processQueries(Collection<? extends OmegaQuery<I,D>> omegaQueries)

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

answerQuery, asOracle, processBatch, processQuery

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

shutdown, shutdownNow

Constructor Detail

DynamicParallelOmegaOracle

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

Method Detail

processQueries

public void processQueries(Collection<? extends OmegaQuery<I,D>> omegaQueries)

Specified by:

processQueries in interface OmegaMembershipOracle<S,I,D>

getMembershipOracle

public MembershipOracle<I,D> getMembershipOracle()

Description copied from interface: OmegaMembershipOracle

Returns a regular membership oracle.

Specified by:

getMembershipOracle in interface OmegaMembershipOracle<S,I,D>

Returns:

a regular membership oracle.

isSameState

public boolean isSameState(Word<I> w1,
                           S s1,
                           Word<I> w2,
                           S s2)

Description copied from interface: OmegaMembershipOracle

Returns whether two states are equal, or if both access sequences w1, and w2 end up in the same state. If both access sequences end up in the same state then s1.equals(s2) must hold.

Specified by:

isSameState in interface OmegaMembershipOracle<S,I,D>

Parameters:

w1 - the first access sequence.

s1 - the first state.

w2 - the second access sequence.

s2 - the second state.

Returns:

whether both states, or states via the given access sequences are equal.

See Also:

ObservableSUL.getState()