de.hybris.platform.ruleengine.concurrency.impl

Class DefaultRuleEngineTaskProcessor<I extends ItemModel>

java.lang.Object

de.hybris.platform.ruleengine.concurrency.impl.DefaultRuleEngineTaskProcessor<I>

Type Parameters:

I - type of ItemModel in the list

All Implemented Interfaces:

RuleEngineSpliteratorStrategy, RuleEngineTaskProcessor<I,TaskResult>

public class DefaultRuleEngineTaskProcessor<I extends ItemModel>
extends java.lang.Object
implements RuleEngineTaskProcessor<I,TaskResult>, RuleEngineSpliteratorStrategy

Default implementation of RuleEngineTaskProcessor

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.platform.ruleengine.concurrency.RuleEngineSpliteratorStrategy

RuleEngineSpliteratorStrategy.Type

Constructor Summary

Constructors

Constructor and Description
DefaultRuleEngineTaskProcessor()

Method Summary

Modifier and Type	Method and Description
protected java.lang.Thread	createAndStartNewWorker(java.util.List<I> items, java.util.function.Consumer<java.util.List<I>> taskConsumer)
TaskExecutionFuture<TaskResult>	execute(java.util.List<I> items, java.util.function.Consumer<java.util.List<I>> taskConsumer) Process the items in the list in multi-thread mode with provided items consumer
TaskExecutionFuture<TaskResult>	execute(java.util.List<I> items, java.util.function.Consumer<java.util.List<I>> taskConsumer, long predestroyTimeout) Process the items in the list in multi-thread mode with provided items consumer
int	getNumberOfThreads() get the number of threads to be allocated for spliterator
protected SuspendResumeTaskManager	getSuspendResumeTaskManager()
protected Tenant	getTenant()
protected java.util.concurrent.ThreadFactory	getTenantAwareThreadFactory()
void	setSuspendResumeTaskManager(SuspendResumeTaskManager suspendResumeTaskManager)
void	setTenant(Tenant tenant)
void	setTenantAwareThreadFactory(java.util.concurrent.ThreadFactory tenantAwareThreadFactory)

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.RuleEngineSpliteratorStrategy

getPartitionSize

Constructor Detail

DefaultRuleEngineTaskProcessor

public DefaultRuleEngineTaskProcessor()

Method Detail

execute

public TaskExecutionFuture<TaskResult> execute(java.util.List<I> items,
                                               java.util.function.Consumer<java.util.List<I>> taskConsumer)

Description copied from interface: RuleEngineTaskProcessor

Process the items in the list in multi-thread mode with provided items consumer

Specified by:

execute in interface RuleEngineTaskProcessor<I extends ItemModel,TaskResult>

Parameters:

items - the list of items to process

taskConsumer - instance of Consumer encapsulating the processing logic

Returns:

The TaskExecutionFuture of the execution process

execute

public TaskExecutionFuture<TaskResult> execute(java.util.List<I> items,
                                               java.util.function.Consumer<java.util.List<I>> taskConsumer,
                                               long predestroyTimeout)

Description copied from interface: RuleEngineTaskProcessor

Process the items in the list in multi-thread mode with provided items consumer

Specified by:

execute in interface RuleEngineTaskProcessor<I extends ItemModel,TaskResult>

Parameters:

items - the list of items to process

taskConsumer - instance of Consumer encapsulating the processing logic

predestroyTimeout - time in milliseconds to wait until forcing the thread join (to prevent eventual thread blocking)

Returns:

The TaskExecutionFuture of the execution process

getNumberOfThreads

public int getNumberOfThreads()

Description copied from interface: RuleEngineSpliteratorStrategy

get the number of threads to be allocated for spliterator

Specified by:

getNumberOfThreads in interface RuleEngineSpliteratorStrategy

Returns:

number of threads to allocate

createAndStartNewWorker

protected java.lang.Thread createAndStartNewWorker(java.util.List<I> items,
                                                   java.util.function.Consumer<java.util.List<I>> taskConsumer)

getTenant

protected Tenant getTenant()

setTenant

public void setTenant(Tenant tenant)

getTenantAwareThreadFactory

protected java.util.concurrent.ThreadFactory getTenantAwareThreadFactory()

setTenantAwareThreadFactory

public void setTenantAwareThreadFactory(java.util.concurrent.ThreadFactory tenantAwareThreadFactory)

getSuspendResumeTaskManager

protected SuspendResumeTaskManager getSuspendResumeTaskManager()

setSuspendResumeTaskManager

public void setSuspendResumeTaskManager(SuspendResumeTaskManager suspendResumeTaskManager)