Package de.hybris.platform.ruleengineservices.maintenance.impl

Class DefaultRuleCompilerSpliterator<T extends SourceRuleModel>

java.lang.Object

de.hybris.platform.ruleengineservices.maintenance.impl.DefaultRuleCompilerSpliterator<T>

All Implemented Interfaces:

RuleCompilerSpliterator<T>

public class DefaultRuleCompilerSpliterator<T extends SourceRuleModel>
extends java.lang.Object
implements RuleCompilerSpliterator<T>

Default implementation of the RuleCompilerSpliterator for SourceRuleModel rules

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultRuleCompilerSpliterator.JobProvider

Method Summary

Modifier and Type	Method	Description
RuleCompilerFuture	compileRulesAsync(java.util.List<T> rules, java.lang.String moduleName)	split and compile multiple rules in parallel
RuleCompilerResult	compileSingleRule(T rule, java.lang.String moduleName)	compile the single rule
protected RuleCompilerFuture	createNewRuleCompilerFuture(java.util.Set<java.lang.Thread> workers)
protected java.lang.Thread	createNewWorker(java.util.List<T> rules, java.lang.String moduleName, java.util.List<RuleCompilerResult> ruleCompilerResults)
protected java.util.List<java.util.List<T>>	splitRules(java.util.List<T> rules)
protected void	startWorkers(java.util.Set<java.lang.Thread> workers)

Methods inherited from class java.lang.Object

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

Method Detail

compileSingleRule

public RuleCompilerResult compileSingleRule(T rule,
                                            java.lang.String moduleName)

Description copied from interface: RuleCompilerSpliterator

compile the single rule

Specified by:

compileSingleRule in interface RuleCompilerSpliterator<T extends SourceRuleModel>

Parameters:

rule - the instance of AbstractRuleModel to compile

moduleName - rules module name

Returns:

instance of RuleCompilerResult

compileRulesAsync

public RuleCompilerFuture compileRulesAsync(java.util.List<T> rules,
                                            java.lang.String moduleName)

Description copied from interface: RuleCompilerSpliterator

split and compile multiple rules in parallel

Specified by:

compileRulesAsync in interface RuleCompilerSpliterator<T extends SourceRuleModel>

Parameters:

rules - a list of AbstractRuleModel to compile

moduleName - rules module name

Returns:

instance of RuleCompilerFuture

splitRules

protected java.util.List<java.util.List<T>> splitRules(java.util.List<T> rules)

createNewWorker

protected java.lang.Thread createNewWorker(java.util.List<T> rules,
                                           java.lang.String moduleName,
                                           java.util.List<RuleCompilerResult> ruleCompilerResults)

startWorkers

protected void startWorkers(java.util.Set<java.lang.Thread> workers)

createNewRuleCompilerFuture

protected RuleCompilerFuture createNewRuleCompilerFuture(java.util.Set<java.lang.Thread> workers)