de.hybris.platform.ruleengineservices.maintenance

Class RuleCompilerFuture

java.lang.Object

de.hybris.platform.ruleengine.concurrency.impl.DefaultTaskExecutionFuture

de.hybris.platform.ruleengineservices.maintenance.RuleCompilerFuture

All Implemented Interfaces:

TaskExecutionFuture<TaskResult>

public class RuleCompilerFuture
extends DefaultTaskExecutionFuture

The implementation of the rules compilation task future, used to collect the RuleCompilerResult and wait for the workers to join the main thread

Constructor Summary

Constructors

Constructor and Description
RuleCompilerFuture(java.util.Set<java.lang.Thread> workers, java.lang.Long workerPreDestroyTimeout)

Method Summary

Modifier and Type	Method and Description
void	addRuleCompilerResults(java.util.List<RuleCompilerResult> ruleCompilerResults) Adds the list of RuleCompilerResult to this future.
protected java.util.List<RuleCompilerResult>	getRuleCompilerResults()
TaskResult	getTaskResult() Blocks until the task execution finishes (all threads join) and returns the list of RuleCompilerResult
long	getWorkerPreDestroyTimeout()

Methods inherited from class de.hybris.platform.ruleengine.concurrency.impl.DefaultTaskExecutionFuture

waitForTasksToFinish

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.hybris.platform.ruleengine.concurrency.TaskExecutionFuture

waitForTasksToFinish, waitWhileWorkerIsRunning

Constructor Detail

RuleCompilerFuture

public RuleCompilerFuture(java.util.Set<java.lang.Thread> workers,
                          java.lang.Long workerPreDestroyTimeout)

Method Detail

getTaskResult

public TaskResult getTaskResult()

Blocks until the task execution finishes (all threads join) and returns the list of RuleCompilerResult

Specified by:

getTaskResult in interface TaskExecutionFuture<TaskResult>

Overrides:

getTaskResult in class DefaultTaskExecutionFuture

Returns:

list of RuleCompilerResult

getWorkerPreDestroyTimeout

public long getWorkerPreDestroyTimeout()

Specified by:

getWorkerPreDestroyTimeout in interface TaskExecutionFuture<TaskResult>

Overrides:

getWorkerPreDestroyTimeout in class DefaultTaskExecutionFuture

addRuleCompilerResults

public void addRuleCompilerResults(java.util.List<RuleCompilerResult> ruleCompilerResults)

Adds the list of RuleCompilerResult to this future. These results are supposed to keep track of the rule compilation execution within the same rules partition

Parameters:

ruleCompilerResults - list of RuleCompilerResult

getRuleCompilerResults

protected java.util.List<RuleCompilerResult> getRuleCompilerResults()