Merge pull request #520 from MilosKozak/waitqueue

synchronized wait
This commit is contained in:
Milos Kozak 2017-12-03 22:48:03 +01:00 committed by GitHub
commit 1c1ef26c84
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -433,6 +433,7 @@ public class DanaRExecutionService extends Service {
} }
final Object o = new Object(); final Object o = new Object();
synchronized(o) {
ConfigBuilderPlugin.getCommandQueue().independentConnect("bolusingInterrupted", new Callback() { ConfigBuilderPlugin.getCommandQueue().independentConnect("bolusingInterrupted", new Callback() {
@Override @Override
public void run() { public void run() {
@ -442,14 +443,17 @@ public class DanaRExecutionService extends Service {
} else { } else {
log.debug("Bolus amount in history too old: " + danaRPump.lastBolusTime.toLocaleString()); log.debug("Bolus amount in history too old: " + danaRPump.lastBolusTime.toLocaleString());
} }
synchronized (o) {
o.notify(); o.notify();
} }
}
}); });
try { try {
o.wait(); o.wait();
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} }
}
} else { } else {
ConfigBuilderPlugin.getCommandQueue().readStatus("bolusOK", null); ConfigBuilderPlugin.getCommandQueue().readStatus("bolusOK", null);
} }