Top Description Fields Constructors Methods

org.testng.internal.thread.graph

public Class GraphOrchestrator<T>

Class Inheritance

extends Object

java.lang.Object
org.testng.internal.thread.graph.GraphOrchestrator

Imports

java.util.Comparator, .List, .Map, java.util.concurrent.*, org.testng.IDynamicGraph, org.testng.collections.Maps, org.testng.internal.AutoCloseableLock, .RuntimeBehavior, org.testng.log4testng.Logger, org.testng.thread.IThreadWorkerFactory, .IWorker

An orchestrator that works with a IDynamicGraph graph to execute nodes from the DAG in an concurrent fashion by using a ThreadPoolExecutor

Field Summary

Modifier and Type	Field and Description
private final Comparator<T>	comparator
private final IThreadWorkerFactory<T>	factory
private final IDynamicGraph<T>	graph
private final AutoCloseableLock	internalLock
private final Map<T, IWorker<T>>	mapping
private final ExecutorService	service
private final Map<T, T>	upstream

Constructor Summary

Access	Constructor and Description
public	GraphOrchestrator(ExecutorService service, IThreadWorkerFactory<T> factory, IDynamicGraph<T> graph, Comparator<T> comparator)

Method Summary

Modifier and Type	Method and Description
private void	afterExecute(IWorker<T> r, Throwable t)
private IDynamicGraph.Status	computeStatus(IWorker<T> worker)
private void	handleThreadAffinity(List<T> freeNodes)
private void	mapNodeToParent(List<T> freeNodes)
private void	mapNodeToWorker(List<IWorker<T>> runnables, List<T> freeNodes)
public void	run()
private void	runNodes(List<T> freeNodes)
private void	setStatus(IWorker<T> worker, IDynamicGraph.Status status)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

comparator	back to summary
private final Comparator<T> comparator

factory	back to summary
private final IThreadWorkerFactory<T> factory

graph	back to summary
private final IDynamicGraph<T> graph

internalLock	back to summary
private final AutoCloseableLock internalLock

mapping	back to summary
private final Map<T, IWorker<T>> mapping

service	back to summary
private final ExecutorService service

upstream	back to summary
private final Map<T, T> upstream

Constructor Detail

GraphOrchestrator	back to summary
public GraphOrchestrator(ExecutorService service, IThreadWorkerFactory<T> factory, IDynamicGraph<T> graph, Comparator<T> comparator)

Method Detail

afterExecute	back to summary
private void afterExecute(IWorker<T> r, Throwable t)

computeStatus	back to summary
private IDynamicGraph.Status computeStatus(IWorker<T> worker)

handleThreadAffinity	back to summary
private void handleThreadAffinity(List<T> freeNodes)

mapNodeToParent	back to summary
private void mapNodeToParent(List<T> freeNodes)

mapNodeToWorker	back to summary
private void mapNodeToWorker(List<IWorker<T>> runnables, List<T> freeNodes)

run	back to summary
public void run()

runNodes	back to summary
private void runNodes(List<T> freeNodes)

setStatus	back to summary
private void setStatus(IWorker<T> worker, IDynamicGraph.Status status)