I
- input symbol typeD
- output domain type@ParametersAreNonnullByDefault public class DynamicParallelOracle<I,D> extends Object implements ParallelOracle<I,D>
ParallelOracle.PoolPolicy
MembershipOracle.DFAMembershipOracle<I>, MembershipOracle.MealyMembershipOracle<I,O>
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BATCH_SIZE |
static ParallelOracle.PoolPolicy |
DEFAULT_POOL_POLICY |
static int |
DEFAULT_POOL_SIZE |
Constructor and Description |
---|
DynamicParallelOracle(Supplier<? extends MembershipOracle<I,D>> oracleSupplier,
int batchSize,
ExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
void |
processQueries(Collection<? extends Query<I,D>> queries)
Processes the specified collection of queries.
|
void |
shutdown()
Shuts down all worker threads, but waits for any queued queries
to be processed.
|
void |
shutdownNow()
Shuts down all worker threads, and attempts to abort any query
processing currently taking place.
|
public static final int DEFAULT_BATCH_SIZE
public static final int DEFAULT_POOL_SIZE
public static final ParallelOracle.PoolPolicy DEFAULT_POOL_POLICY
public DynamicParallelOracle(Supplier<? extends MembershipOracle<I,D>> oracleSupplier, @Nonnegative int batchSize, ExecutorService executor)
public void shutdown()
ParallelOracle
shutdown
in interface ParallelOracle<I,D>
ExecutorService.shutdown()
public void shutdownNow()
ParallelOracle
shutdownNow
in interface ParallelOracle<I,D>
ExecutorService.shutdownNow()
public void processQueries(Collection<? extends Query<I,D>> queries)
MembershipOracle
processQueries
in interface MembershipOracle<I,D>
queries
- the queries to processDefaultQuery.getOutput()
Copyright © 2015. All rights reserved.