Class TaskTideEngineWorker

java.lang.Object

org.tasktide.engine.worker.TaskTideEngineWorker

All Implemented Interfaces:

Cloneable

public class TaskTideEngineWorker
extends Object
implements Cloneable

Engine worker using the TargetedAcquisitionPolicy interface to acquire a workload to process, and process them through the TaskTideWorkloadTraverser interface. Update simplifies the TaskTide-EngineClient, and EngineUtility methods

Constructor Summary

Constructors

Constructor	Description
TaskTideEngineWorker(TaskTideWorkloadAcquisitionPolicy policy)	Construct with TargetedAcquisitionPolicy.
TaskTideEngineWorker(TaskTideWorkloadAcquisitionPolicy policy, boolean shouldCycle)	Construct with TargetedAcquisitionPolicy.

Method Summary

Modifier and Type	Method	Description
TaskTideEngineWorker	clone()	Clone active TaskTideEngineWorker
void	fetchAndRun()	Consumes random samplings of tasks from TaskTideWorkloadAcquisitionPolicy until all tasks have been processed
TaskTideWorkloadAcquisitionPolicy	getPolicy()	Get the TargetedAcquisitionPolicy
void	runEngine(WorkerExecutionPolicy executionPolicy)	Entry-point method for implementing classes

Methods inherited from class Object

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

Constructor Details

TaskTideEngineWorker

public TaskTideEngineWorker(TaskTideWorkloadAcquisitionPolicy policy)

Construct with TargetedAcquisitionPolicy. Defaults shouldCycle property for WorkflowAcquisitionPolicy-Sequential running in Service mode to false.

Parameters:

policy -

TaskTideEngineWorker

public TaskTideEngineWorker(TaskTideWorkloadAcquisitionPolicy policy,
 boolean shouldCycle)

Construct with TargetedAcquisitionPolicy. Supplying shouldCycle property for WorkflowAcquisitionPolicy-Sequential running in Service mode to false.

Parameters:

policy -

shouldCycle -

Method Details

getPolicy

public TaskTideWorkloadAcquisitionPolicy getPolicy()

Get the TargetedAcquisitionPolicy

Returns:

TargetedAcquisitionPolicy

fetchAndRun

public void fetchAndRun()

Consumes random samplings of tasks from TaskTideWorkloadAcquisitionPolicy until all tasks have been processed

runEngine

public void runEngine(WorkerExecutionPolicy executionPolicy)
               throws TaskTideEngineCheckedException

Entry-point method for implementing classes

Parameters:

executionPolicy -

Throws:

TaskTideEngineCheckedException

clone

public TaskTideEngineWorker clone()

Clone active TaskTideEngineWorker

Overrides:

clone in class Object

Returns:

TaskTideEngineWorker