de.hybris.platform.ruleengine.concurrency.impl

Class DefaultTaskExecutionFuture

java.lang.Object

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

All Implemented Interfaces:

TaskExecutionFuture<TaskResult>

Direct Known Subclasses:

RuleCompilerFuture, RulePublishingFuture

public class DefaultTaskExecutionFuture
extends java.lang.Object
implements TaskExecutionFuture<TaskResult>

Default barebones implementation of TaskExecutionFuture

Constructor Summary

Constructors

Constructor and Description
DefaultTaskExecutionFuture(java.util.Set<java.lang.Thread> workers)
DefaultTaskExecutionFuture(java.util.Set<java.lang.Thread> workers, long predestroyTimeout)

Method Summary

Modifier and Type	Method and Description
TaskResult	getTaskResult()
long	getWorkerPreDestroyTimeout()
void	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

DefaultTaskExecutionFuture

public DefaultTaskExecutionFuture(java.util.Set<java.lang.Thread> workers)

DefaultTaskExecutionFuture

public DefaultTaskExecutionFuture(java.util.Set<java.lang.Thread> workers,
                                  long predestroyTimeout)

Method Detail

getTaskResult

public TaskResult getTaskResult()

Specified by:

getTaskResult in interface TaskExecutionFuture<TaskResult>

getWorkerPreDestroyTimeout

public long getWorkerPreDestroyTimeout()

Specified by:

getWorkerPreDestroyTimeout in interface TaskExecutionFuture<TaskResult>

waitForTasksToFinish

public void waitForTasksToFinish()

Specified by:

waitForTasksToFinish in interface TaskExecutionFuture<TaskResult>