diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java index 18b837878d895ab70fcb54564f8bec751ba71671..578ea97408db2c5747090c348793061e4598a2f2 100644 --- a/src/main/java/teetime/framework/Analysis.java +++ b/src/main/java/teetime/framework/Analysis.java @@ -265,13 +265,13 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught private void sendInitializingSignal() { for (RunnableProducerStage runnable : producerRunnables) { - runnable.sendInitializingSignal(); + runnable.triggerInitializingSignal(); } } private void sendStartingSignal() { for (RunnableProducerStage runnable : producerRunnables) { - runnable.sendStartingSignal(); + runnable.triggerStartingSignal(); } } diff --git a/src/main/java/teetime/framework/RunnableProducerStage.java b/src/main/java/teetime/framework/RunnableProducerStage.java index 14ce4563f46bd65d5bdb1f9af5b22baece3fe5a7..f8e9eb482df8956166be0ed421d1b51472d4ab9d 100644 --- a/src/main/java/teetime/framework/RunnableProducerStage.java +++ b/src/main/java/teetime/framework/RunnableProducerStage.java @@ -49,11 +49,11 @@ final class RunnableProducerStage extends AbstractRunnableStage { this.stage.onSignal(terminatingSignal, null); } - public void sendInitializingSignal() { + public void triggerInitializingSignal() { initSemaphore.release(); } - public void sendStartingSignal() { + public void triggerStartingSignal() { startSemaphore.release(); } diff --git a/src/test/java/teetime/framework/RunnableProducerStageTest.java b/src/test/java/teetime/framework/RunnableProducerStageTest.java index db2fec7c3aa28d799204cc3a711fafc31e1c02e1..387dd622513260e9ea08a0df5b21e7b06064513c 100644 --- a/src/test/java/teetime/framework/RunnableProducerStageTest.java +++ b/src/test/java/teetime/framework/RunnableProducerStageTest.java @@ -15,10 +15,10 @@ public class RunnableProducerStageTest { thread.start(); // Not running and not initialized assertFalse(testStage.executed && testStage.initialized); - runnable.sendInitializingSignal(); + runnable.triggerInitializingSignal(); // Not running, but initialized assertFalse(testStage.executed && !testStage.initialized); - runnable.sendStartingSignal(); + runnable.triggerStartingSignal(); while (!testStage.shouldBeTerminated()) { Thread.yield();