Class WorkItemTraverser

java.lang.Object

org.tasktide.engine.traversers.WorkItemTraverser

All Implemented Interfaces:

TaskTideWorkloadTraverser<WorkItem>, TaskTideWorkerUnit<WorkItem>

public class WorkItemTraverser
extends Object
implements TaskTideWorkloadTraverser<WorkItem>

Class to hold logic for fetching a workload from the TaskTideServiceManager. Utilizing the TaskTideEngineObserver, ItemTaskTraverser, and ItemTaskExecutor to handle how workload is consumed.

Method Summary

Modifier and Type	Method	Description
void	parallelSubmit(List<WorkItem> workload)	Schedules each WorkItem of provided workload into ExecutorService thread pool.
boolean	processElm(WorkItem elm)	Handles the pre-processing for WorkItem
void	serialSubmit(List<WorkItem> workload)	Traverses provided workload processing elements passing validation
void	traverse(List<WorkItem> workload)	Traverse provided workload

Methods inherited from class Object

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

Method Details

traverse

public void traverse(List<WorkItem> workload)
              throws TraverserCheckedException

Traverse provided workload

Specified by:

traverse in interface TaskTideWorkloadTraverser<WorkItem>

Parameters:

workload -

Throws:

TraverserCheckedException

serialSubmit

public void serialSubmit(List<WorkItem> workload)
                  throws TraverserCheckedException

Traverses provided workload processing elements passing validation

Parameters:

workload -

Throws:

TraverserCheckedException

parallelSubmit

public void parallelSubmit(List<WorkItem> workload)
                    throws TraverserCheckedException

Schedules each WorkItem of provided workload into ExecutorService thread pool. Using the FutureTrackers container to fetch TrackerWaiter

Parameters:

workload -

Throws:

TraverserCheckedException

processElm

public boolean processElm(WorkItem elm)
                   throws TraverserCheckedException

Handles the pre-processing for WorkItem

Specified by:

processElm in interface TaskTideWorkloadTraverser<WorkItem>

Parameters:

elm -

Returns:

boolean

Throws:

TraverserCheckedException