Skip to content
Snippets Groups Projects
Commit 5b5bc556 authored by Christian Wulf's avatar Christian Wulf
Browse files

updated javadoc

parent 5d68729e
No related branches found
No related tags found
No related merge requests found
......@@ -23,11 +23,6 @@ public abstract class ConsumerStage<I> extends AbstractStage {
// do nothing
}
/**
*
* @return <code>true</code> iff this stage makes progress when it is re-executed by the scheduler, otherwise <code>false</code>.<br>
* For example, many stages are re-schedulable if at least one of their input ports are not empty.
*/
protected boolean determineReschedulability() {
return this.inputPort.getPipe().size() > 0;
}
......
package teetime.variant.methodcallWithPorts.framework.core;
/**
* The <code>ProducerStage</code> produces at least one element at each execution.<br>
*
* @reschedulability
* This stage is executed as long as its execute() method decided to do so.<br>
* Refer to {@link AbstractStage#isReschedulable} for more information.
*
* @author Christian Wulf
*
* @param <O>
* the type of the default output port
*
*/
public abstract class ProducerStage<O> extends AbstractStage {
protected final OutputPort<O> outputPort = this.createOutputPort();
......
......@@ -12,6 +12,10 @@ public interface StageWithPort {
// void setListener(OnDisableListener listener);
/**
* @return <code>true</code> iff this stage makes progress when it is re-executed by the scheduler, otherwise <code>false</code>.<br>
* For example, many stages are re-schedulable if at least one of their input ports are not empty.
*/
boolean isReschedulable();
void onIsPipelineHead();
......
Subproject commit 75998aa20b7ec897ec321c1f94192de888f2dc6e
Subproject commit 88e1e25f9519b250258c7e5ada30935975ab2d10
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