de.learnlib.parallelism

Class ParallelOracle<I,O>

java.lang.Object

de.learnlib.parallelism.ParallelOracle<I,O>

Type Parameters:

I - input symbol class

O - output class

All Implemented Interfaces:

MembershipOracle<I,O>

public class ParallelOracle<I,O>
extends Object
implements MembershipOracle<I,O>

A membership oracle that distributes a set of queries among several threads.

Author:

Malte Isberner

Nested Class Summary

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

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

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MIN_BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
ParallelOracle(List<? extends MembershipOracle<I,O>> oracles) Constructor for using (potentially) separate oracles for each worker thread, with a default minimum batch size.
ParallelOracle(List<? extends MembershipOracle<I,O>> oracles, int minBatchSize) Constructor for using (potentially) separate oracles for each worker thread.
ParallelOracle(MembershipOracle<I,O> sharedOracle, int numInstances) Constructor for using one shared oracle for all worker threads, with the default minimum batch size.
ParallelOracle(MembershipOracle<I,O> sharedOracle, int numInstances, int minBatchSize) Constructor for using one shared oracle for all worker threads, with a custom minimum batch size.

Method Summary

Methods

Modifier and Type	Method and Description
void	processQueries(Collection<? extends Query<I,O>> queries) Processes the specified collection of queries.
void	start() Starts all worker threads.
void	stop() Stop all worker threads.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MIN_BATCH_SIZE

public static int DEFAULT_MIN_BATCH_SIZE

Constructor Detail

ParallelOracle

public ParallelOracle(List<? extends MembershipOracle<I,O>> oracles)

Constructor for using (potentially) separate oracles for each worker thread, with a default minimum batch size.

Parameters:

oracles - the oracles to use for answering the queries. The cardinality of this list coincides with the number of threads created.

ParallelOracle

public ParallelOracle(List<? extends MembershipOracle<I,O>> oracles,
              int minBatchSize)

Constructor for using (potentially) separate oracles for each worker thread.

Parameters:

oracles - the oracles to use for answering the queries. The cardinality of this list coincides with the number of threads created.

minBatchSize - the minimum batch size

ParallelOracle

public ParallelOracle(MembershipOracle<I,O> sharedOracle,
              int numInstances)

Constructor for using one shared oracle for all worker threads, with the default minimum batch size.

Parameters:

sharedOracle - the shared oracle

numInstances - the number of threads to create

ParallelOracle

public ParallelOracle(MembershipOracle<I,O> sharedOracle,
              int numInstances,
              int minBatchSize)

Constructor for using one shared oracle for all worker threads, with a custom minimum batch size.

Parameters:

sharedOracle - the shared oracle

numInstances - the number of threads to create

minBatchSize - the minimum batch size

Method Detail

start

public void start()

Starts all worker threads.

processQueries

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

Description copied from interface: MembershipOracle

Processes the specified collection of queries. When this method returns, the output field of each of the contained queries should reflect the SUL response to the respective query.

Specified by:

processQueries in interface MembershipOracle<I,O>

Parameters:

queries - the queries to process

See Also:

DefaultQuery.getOutput()

stop

public void stop()

Stop all worker threads. After this method has been called, invoking processQueries(Collection) will result in an IllegalStateException until the next call to start() is made.