From 46d4c053db9a363185a9dce28fcefbc3bf9d6afd Mon Sep 17 00:00:00 2001 From: Fabian Stemmler Date: Fri, 20 Sep 2019 16:53:09 +0200 Subject: [PATCH] Simulation can now be slowed and paused --- .../core/timeline/PauseableTimeFunction.java | 58 +++++++++++++++++++ .../mograsim/logic/model/LogicExecuter.java | 45 +++++++++++++- .../mograsim/plugin/views/LogicUIPart.java | 50 ++++++++++++++++ 3 files changed, 151 insertions(+), 2 deletions(-) create mode 100644 plugins/net.mograsim.logic.core/src/net/mograsim/logic/core/timeline/PauseableTimeFunction.java diff --git a/plugins/net.mograsim.logic.core/src/net/mograsim/logic/core/timeline/PauseableTimeFunction.java b/plugins/net.mograsim.logic.core/src/net/mograsim/logic/core/timeline/PauseableTimeFunction.java new file mode 100644 index 00000000..86f4ce99 --- /dev/null +++ b/plugins/net.mograsim.logic.core/src/net/mograsim/logic/core/timeline/PauseableTimeFunction.java @@ -0,0 +1,58 @@ +package net.mograsim.logic.core.timeline; + +import java.util.function.LongSupplier; + +public class PauseableTimeFunction implements LongSupplier +{ + private boolean paused = false; + private long unpausedSysTime = 0, lastPausedInternalTime = 0; + private int speedPercentage = 100; + + public void pause() + { + if (!paused) + { + lastPausedInternalTime = getAsLong(); + paused = true; + } + } + + public void unpause() + { + if (paused) + { + paused = false; + unpausedSysTime = System.currentTimeMillis(); + } + } + + @Override + public long getAsLong() + { + return paused ? lastPausedInternalTime + : lastPausedInternalTime + ((System.currentTimeMillis() - unpausedSysTime) * speedPercentage) / 100; + } + + public void setSpeedPercentage(int percentage) + { + if (!paused) + { + pause(); + unpause(); + } + this.speedPercentage = Integer.min(100, Integer.max(percentage, 1)); + } + + public boolean isPaused() + { + return paused; + } + + public void toggle() + { + if (paused) + unpause(); + else + pause(); + } +} diff --git a/plugins/net.mograsim.logic.model/src/net/mograsim/logic/model/LogicExecuter.java b/plugins/net.mograsim.logic.model/src/net/mograsim/logic/model/LogicExecuter.java index a9fde7a1..eb67f8dc 100644 --- a/plugins/net.mograsim.logic.model/src/net/mograsim/logic/model/LogicExecuter.java +++ b/plugins/net.mograsim.logic.model/src/net/mograsim/logic/model/LogicExecuter.java @@ -3,6 +3,7 @@ package net.mograsim.logic.model; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicLong; +import net.mograsim.logic.core.timeline.PauseableTimeFunction; import net.mograsim.logic.core.timeline.Timeline; //TODO maybe move to logic core? @@ -13,16 +14,21 @@ public class LogicExecuter private final AtomicBoolean shouldBeRunningLive; private final AtomicBoolean isRunningLive; + private final AtomicBoolean isPaused; private final AtomicLong nextExecSimulTime; private final Thread simulationThread; + PauseableTimeFunction tf; + public LogicExecuter(Timeline timeline) { this.timeline = timeline; - timeline.setTimeFunction(System::currentTimeMillis); + tf = new PauseableTimeFunction(); + timeline.setTimeFunction(tf); shouldBeRunningLive = new AtomicBoolean(); isRunningLive = new AtomicBoolean(); + isPaused = new AtomicBoolean(); nextExecSimulTime = new AtomicLong(); simulationThread = new Thread(() -> { @@ -36,7 +42,7 @@ public class LogicExecuter while (shouldBeRunningLive.get()) { // always execute to keep timeline from "hanging behind" for too long - long current = System.currentTimeMillis(); + long current = tf.getAsLong(); timeline.executeUntil(timeline.laterThan(current), current + 10); long sleepTime; if (timeline.hasNext()) @@ -48,6 +54,12 @@ public class LogicExecuter nextExecSimulTime.set(current + sleepTime); if (sleepTime > 0) Thread.sleep(sleepTime); + + synchronized (isPaused) + { + while (isPaused.get()) + isPaused.wait(); + } } catch (@SuppressWarnings("unused") InterruptedException e) {// do nothing; it is normal execution flow to be interrupted @@ -94,6 +106,35 @@ public class LogicExecuter waitForIsRunning(false); } + public void unpauseLiveExecution() + { + synchronized (isPaused) + { + tf.unpause(); + isPaused.set(false); + isPaused.notify(); + } + } + + public void pauseLiveExecution() + { + synchronized (isPaused) + { + tf.pause(); + isPaused.set(true); + } + } + + public boolean isPaused() + { + return isPaused.get(); + } + + public void setSpeedPercentage(int percentage) + { + tf.setSpeedPercentage(percentage); + } + private void waitForIsRunning(boolean expectedState) { while (isRunningLive.get() ^ expectedState) diff --git a/plugins/net.mograsim.plugin.core/src/net/mograsim/plugin/views/LogicUIPart.java b/plugins/net.mograsim.plugin.core/src/net/mograsim/plugin/views/LogicUIPart.java index 49c6fa43..42c2db4a 100644 --- a/plugins/net.mograsim.plugin.core/src/net/mograsim/plugin/views/LogicUIPart.java +++ b/plugins/net.mograsim.plugin.core/src/net/mograsim/plugin/views/LogicUIPart.java @@ -6,7 +6,10 @@ import org.eclipse.e4.ui.model.application.ui.basic.MPart; import org.eclipse.swt.SWT; import org.eclipse.swt.layout.GridData; import org.eclipse.swt.layout.GridLayout; +import org.eclipse.swt.widgets.Button; import org.eclipse.swt.widgets.Composite; +import org.eclipse.swt.widgets.Label; +import org.eclipse.swt.widgets.Slider; import org.eclipse.ui.PlatformUI; import org.eclipse.ui.part.ViewPart; @@ -51,6 +54,8 @@ public class LogicUIPart extends ViewPart GridLayout layout = new GridLayout(1, true); parent.setLayout(layout); + addSimulationControlWidgets(parent); + ui = new LogicUICanvas(parent, SWT.NONE, m.getModel()); ui.addTransformListener((x, y, z) -> part.setDirty(z < 1)); ZoomableCanvasUserInput userInput = new ZoomableCanvasUserInput(ui); @@ -79,6 +84,51 @@ public class LogicUIPart extends ViewPart exec.startLiveExecution(); } + private void addSimulationControlWidgets(Composite parent) + { + Composite c = new Composite(parent, SWT.NONE); + c.setLayout(new GridLayout(4, false)); + Button pauseButton = new Button(c, SWT.TOGGLE); + pauseButton.setText("Running"); + + pauseButton.addListener(SWT.Selection, e -> + { + if (!pauseButton.getSelection()) + { + pauseButton.setText("Running"); + exec.unpauseLiveExecution(); + } else + { + pauseButton.setText("Paused"); + exec.pauseLiveExecution(); + } + }); + + Label speedLabel = new Label(c, SWT.NONE); + speedLabel.setText("Simulation Speed: "); + + Slider slider = new Slider(c, SWT.NONE); + slider.setMinimum(1); + slider.setMaximum(100 + slider.getThumb()); + slider.setIncrement(1); + + Label speedPercentageLabel = new Label(c, SWT.NONE); + speedPercentageLabel.setText("100%"); + + slider.addListener(SWT.Selection, e -> + { + int selection = slider.getSelection(); + speedPercentageLabel.setText(selection + "%"); + + exec.setSpeedPercentage(slider.getSelection()); + }); + slider.setSelection(100); + + c.setLayoutData(new GridData(GridData.GRAB_HORIZONTAL | GridData.FILL_HORIZONTAL)); + c.pack(); + c.setVisible(true); + } + @Override public void setFocus() { -- 2.17.1