diff --git a/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ConsumerStage.java b/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ConsumerStage.java index 1540b1fb68436d0251ae42a871e870f4077049e1..046395a5f0873884fb323788347c6681d48d658d 100644 --- a/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ConsumerStage.java +++ b/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ConsumerStage.java @@ -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; } diff --git a/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ProducerStage.java b/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ProducerStage.java index c1e7c693cb122b2d8aa5370ef965185410c1a326..5a9492154d93e0fca7837199b676bddcf783b0ae 100644 --- a/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ProducerStage.java +++ b/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ProducerStage.java @@ -1,5 +1,18 @@ 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(); diff --git a/src/main/java/teetime/variant/methodcallWithPorts/framework/core/StageWithPort.java b/src/main/java/teetime/variant/methodcallWithPorts/framework/core/StageWithPort.java index bbeb16316085dec098b2140d851c764b844bebe0..72563660a89d85f88d2fe8ab026bae77cd32c501 100644 --- a/src/main/java/teetime/variant/methodcallWithPorts/framework/core/StageWithPort.java +++ b/src/main/java/teetime/variant/methodcallWithPorts/framework/core/StageWithPort.java @@ -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(); diff --git a/submodules/JCTools b/submodules/JCTools index 75998aa20b7ec897ec321c1f94192de888f2dc6e..88e1e25f9519b250258c7e5ada30935975ab2d10 160000 --- a/submodules/JCTools +++ b/submodules/JCTools @@ -1 +1 @@ -Subproject commit 75998aa20b7ec897ec321c1f94192de888f2dc6e +Subproject commit 88e1e25f9519b250258c7e5ada30935975ab2d10