Skip to content
Snippets Groups Projects
Commit 876348e8 authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa
Browse files

javadoc

parent 9a301fb4
No related branches found
No related tags found
No related merge requests found
...@@ -145,10 +145,28 @@ public abstract class AnalysisConfiguration { ...@@ -145,10 +145,28 @@ public abstract class AnalysisConfiguration {
return interUnboundedThreadFactory.create(sourcePort, targetPort, capacity); return interUnboundedThreadFactory.create(sourcePort, targetPort, capacity);
} }
/**
* Connects two ports with a pipe.
*
* @param sourcePort
* port from the sending stage
* @param targetPort
* port from the receiving stage
*/
protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) { protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
connectPorts(sourcePort, targetPort, 4); connectPorts(sourcePort, targetPort, 4);
} }
/**
* Connects to ports with a pipe of a certain capacity
*
* @param sourcePort
* port from the sending stage
* @param targetPort
* port from the receiving stage
* @param capacity
* the pipe is set to this capacity, if the value is greater than 0. If it is 0, than the pipe is unbounded, thus growing of the pipe is enabled.
*/
protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) { protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) {
connections.add(new Connection(sourcePort, targetPort, capacity)); connections.add(new Connection(sourcePort, targetPort, capacity));
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment