Package | Description |
---|---|
com.github.dexecutor.core | |
com.github.dexecutor.core.graph |
Modifier and Type | Method and Description |
---|---|
Future<Node<T,R>> |
ExecutionEngine.submit(Callable<Node<T,R>> task)
Submits a value-returning task for execution and returns a Future
representing the pending results of the task.
|
Future<Node<T,R>> |
DefaultExecutionEngine.submit(Callable<Node<T,R>> task) |
Future<Node<T,R>> |
ExecutionEngine.take()
Retrieves and removes the Future representing the next
completed task, waiting if none are yet present.
|
Future<Node<T,R>> |
DefaultExecutionEngine.take() |
Modifier and Type | Method and Description |
---|---|
Future<Node<T,R>> |
ExecutionEngine.submit(Callable<Node<T,R>> task)
Submits a value-returning task for execution and returns a Future
representing the pending results of the task.
|
Future<Node<T,R>> |
DefaultExecutionEngine.submit(Callable<Node<T,R>> task) |
Modifier and Type | Method and Description |
---|---|
Collection<Node<T,R>> |
DefaultDag.allNodes() |
Collection<Node<T,R>> |
Dag.allNodes()
Returns all nodes in this graph
|
Set<Node<T,R>> |
Node.getInComingNodes() |
Set<Node<T,R>> |
DefaultDag.getInitialNodes() |
Set<Node<T,R>> |
Dag.getInitialNodes()
Returns the Set of nodes for which there is no incoming dependencies.
|
Set<Node<T,R>> |
DefaultDag.getLeafNodes() |
Set<Node<T,R>> |
Dag.getLeafNodes()
Retruns the set of nodes for which there is no outgoing dependencies.
|
Set<Node<T,R>> |
Node.getOutGoingNodes() |
Modifier and Type | Method and Description |
---|---|
void |
Node.addInComingNode(Node<T,R> node)
Add the given node, to the set of incoming nodes
|
void |
Node.addOutGoingNode(Node<T,R> node)
add the given to the set of out going nodes
|
Copyright © 2016 Dexecutor. All rights reserved.