TheCloud/Digital
1
0
Fork 0
mirror of https://github.com/hneemann/Digital.git synced 2025-09-29 07:50:29 -04:00
Code Issues Packages Projects Releases Wiki Activity

passing a lambda expression to thread constructor

Browse Source
This commit is contained in:
hneemann 2017-03-27 19:05:26 +02:00
parent deff384e03
commit 25036d0169
1 changed files with 19 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/main/java/de/neemann/digital/draw/model/RealTimeClock.java
View File

@ -116,30 +116,27 @@ public class RealTimeClock implements ModelStateObserver {
private final Thread thread; private final Thread thread;
ThreadRunner() { ThreadRunner() {
thread = new Thread() { thread = new Thread(() -> {
@Override LOGGER.debug("thread start");
public void run() { long time = System.currentTimeMillis();
LOGGER.debug("thread start"); long counter = 0;
long time = System.currentTimeMillis(); try {
long counter = 0; while (!Thread.interrupted()) {
try { modelSync.accessNEx(() -> {
while (!interrupted()) { output.setValue(1 - output.getValue());
modelSync.accessNEx(() -> { model.doStep();
output.setValue(1 - output.getValue()); });
model.doStep(); counter++;
});
counter++;
}
} catch (NodeException e1) {
stopper.showErrorAndStopModel(Lang.get("msg_clockError"), e1);
} }
time = System.currentTimeMillis() - time; } catch (NodeException e1) {
stopper.showErrorAndStopModel(Lang.get("msg_clockError"), e1);
final long l = counter / time / 2;
status.setStatus(l + "kHz");
LOGGER.debug("thread end, f="+l+"kHz");
} }
}; time = System.currentTimeMillis() - time;
final long l = counter / time / 2;
status.setStatus(l + "kHz");
LOGGER.debug("thread end, f=" + l + "kHz");
});
thread.setDaemon(true); thread.setDaemon(true);
thread.start(); thread.start();
} }