@ParametersAreNonnullByDefault public abstract class ParallelOracleBuilders extends Object
Using the methods defined in this class is the preferred way of instantiating parallel oracles.
Usage examples
Creating a static parallel oracle with a minimum batch size of 20 and a fixed thread pool, using a membership oracle shared by 4 threads:
ParallelOracleBuilders.newStaticParallelOracle(membershipOracle) .withMinBatchSize(20) .withNumInstances(4) .withPoolPolicy(PoolPolicy.FIXED) .create();
Creating a dynamic parallel oracle with a custom executor, and a batch size of 5, using a shared membership oracle:
ParallelOracleBuilders.newDynamicParallelOracle(membershipOracle) .withBatchSize(5) .withCustomExecutor(myExecutor) .create();
Creating a dynamic parallel oracle with a cached thread pool of maximum size 4, a batch size of 5, using an oracle supplier:
ParallelOracleBuilders.newDynamicParallelOracle(oracleSupplier) .withBatchSize(5) .withPoolSize(4) .withPoolPolicy(PoolPolicy.CACHED) .create();
Modifier and Type | Method and Description |
---|---|
static <I,D> DynamicParallelOracleBuilder<I,D> |
newDynamicParallelOracle(MembershipOracle<I,D> sharedOracle) |
static <I,D> DynamicParallelOracleBuilder<I,D> |
newDynamicParallelOracle(Supplier<? extends MembershipOracle<I,D>> oracleSupplier) |
static <I,D> StaticParallelOracleBuilder<I,D> |
newStaticParallelOracle(Collection<? extends MembershipOracle<I,D>> oracles) |
static <I,D> StaticParallelOracleBuilder<I,D> |
newStaticParallelOracle(MembershipOracle<I,D> sharedOracle) |
static <I,D> StaticParallelOracleBuilder<I,D> |
newStaticParallelOracle(MembershipOracle<I,D> firstOracle,
MembershipOracle<I,D>... otherOracles) |
static <I,D> StaticParallelOracleBuilder<I,D> |
newStaticParallelOracle(Supplier<? extends MembershipOracle<I,D>> oracleSupplier) |
@Nonnull public static <I,D> DynamicParallelOracleBuilder<I,D> newDynamicParallelOracle(MembershipOracle<I,D> sharedOracle)
@Nonnull public static <I,D> DynamicParallelOracleBuilder<I,D> newDynamicParallelOracle(Supplier<? extends MembershipOracle<I,D>> oracleSupplier)
@Nonnull public static <I,D> StaticParallelOracleBuilder<I,D> newStaticParallelOracle(MembershipOracle<I,D> sharedOracle)
@Nonnull public static <I,D> StaticParallelOracleBuilder<I,D> newStaticParallelOracle(Supplier<? extends MembershipOracle<I,D>> oracleSupplier)
@Nonnull @SafeVarargs public static <I,D> StaticParallelOracleBuilder<I,D> newStaticParallelOracle(MembershipOracle<I,D> firstOracle, MembershipOracle<I,D>... otherOracles)
@Nonnull public static <I,D> StaticParallelOracleBuilder<I,D> newStaticParallelOracle(Collection<? extends MembershipOracle<I,D>> oracles)
Copyright © 2015. All rights reserved.