public class RuleSetExec extends Object
Modifier and Type | Field and Description |
---|---|
static Comparator<RuleResult> |
DEFAULT_PLAN_COMPARATOR |
static int |
DEFAULT_TIMEOUT |
static int |
MAX_CONCURRENT_PLANNERS |
Constructor and Description |
---|
RuleSetExec(TraceWriter traceWriter,
FlowPlanner flowPlanner,
Flow flow,
RuleRegistrySet registrySet,
FlowDef flowDef,
FlowElementGraph flowElementGraph) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
binResult(RuleResult ruleResult) |
protected Callable<RuleResult> |
createCallable(RuleRegistry ruleRegistry) |
protected List<Callable<RuleResult>> |
createCallables() |
RuleResult |
exec() |
protected RuleResult |
execPlannerFor(RuleRegistry ruleRegistry) |
protected ProcessLogger |
getFlowLogger() |
protected Comparator<RuleResult> |
getOrderComparator() |
protected Comparator<RuleResult> |
getPlanComparator() |
protected Set<Future<RuleResult>> |
submitCallables(List<Callable<RuleResult>> callables) |
public static final int MAX_CONCURRENT_PLANNERS
public static final int DEFAULT_TIMEOUT
public static final Comparator<RuleResult> DEFAULT_PLAN_COMPARATOR
public RuleSetExec(TraceWriter traceWriter, FlowPlanner flowPlanner, Flow flow, RuleRegistrySet registrySet, FlowDef flowDef, FlowElementGraph flowElementGraph)
protected ProcessLogger getFlowLogger()
protected Comparator<RuleResult> getPlanComparator()
protected Comparator<RuleResult> getOrderComparator()
public RuleResult exec()
protected RuleResult execPlannerFor(RuleRegistry ruleRegistry)
protected Set<Future<RuleResult>> submitCallables(List<Callable<RuleResult>> callables)
protected List<Callable<RuleResult>> createCallables()
protected Callable<RuleResult> createCallable(RuleRegistry ruleRegistry)
protected boolean binResult(RuleResult ruleResult)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.