Package | Description |
---|---|
org.shared.parallel |
A framework for specifying and executing parallel dataflow engines.
|
Modifier and Type | Method and Description |
---|---|
Engine.EngineNode<?,? extends O> |
Engine.EngineEdge.getU() |
Engine.EngineNode<? super O,?> |
Engine.EngineEdge.getV() |
Modifier and Type | Method and Description |
---|---|
protected <O> void |
Engine.addEdge(Engine.EngineNode<?,? extends O> u,
Engine.EngineNode<? super O,?> v)
Links two
Engine.EngineNode s by an Engine.EngineEdge . |
protected <O> void |
Engine.addEdge(Engine.EngineNode<?,? extends O> u,
Engine.EngineNode<? super O,?> v)
Links two
Engine.EngineNode s by an Engine.EngineEdge . |
int |
Engine.EngineNode.compareTo(Engine.EngineNode<?,?> node)
Compares traversal orders to determine priority of execution.
|
void |
Engine.EngineEdge.setU(Engine.EngineNode<?,?> node) |
void |
Engine.EngineEdge.setV(Engine.EngineNode<?,?> node) |
Constructor and Description |
---|
Engine.EngineEdge(Engine.EngineNode<?,? extends O> u,
Engine.EngineNode<? super O,?> v)
Default constructor.
|
Engine.EngineEdge(Engine.EngineNode<?,? extends O> u,
Engine.EngineNode<? super O,?> v)
Default constructor.
|
Constructor and Description |
---|
Engine(int nThreads,
TraversalPolicy<Engine.EngineNode<?,?>,Engine.EngineEdge<?>> policy)
Default constructor.
|