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 and Description
static class	DefaultRuleCompilerSpliterator.JobProvider

Method Summary

Modifier and Type	Method and 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)