Ecosystem/haveno
Ecosystem/haveno
2
1
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2024-12-22 19:49:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

make ClockWatcher thread safe

Browse source
This commit is contained in:
woodser 2024-03-28 13:34:01 -04:00
parent b0b5fde742
commit b9ed399036
1 changed files with 25 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
common/src/main/java/haveno/common/ClockWatcher.java
View file

@ -54,25 +54,27 @@ public class ClockWatcher {
if (timer == null) {
lastSecondTick = System.currentTimeMillis();
timer = UserThread.runPeriodically(() -> {
listeners.forEach(Listener::onSecondTick);
counter++;
if (counter >= 60) {
counter = 0;
listeners.forEach(Listener::onMinuteTick);
}
long currentTimeMillis = System.currentTimeMillis();
long diff = currentTimeMillis - lastSecondTick;
if (diff > 1000) {
long missedMs = diff - 1000;
listeners.forEach(listener -> listener.onMissedSecondTick(missedMs));
if (missedMs > ClockWatcher.IDLE_TOLERANCE_MS) {
log.info("We have been in standby mode for {} sec", missedMs / 1000);
listeners.forEach(listener -> listener.onAwakeFromStandby(missedMs));
synchronized (listeners) {
listeners.forEach(Listener::onSecondTick);
counter++;
if (counter >= 60) {
counter = 0;
listeners.forEach(Listener::onMinuteTick);
}
long currentTimeMillis = System.currentTimeMillis();
long diff = currentTimeMillis - lastSecondTick;
if (diff > 1000) {
long missedMs = diff - 1000;
listeners.forEach(listener -> listener.onMissedSecondTick(missedMs));
if (missedMs > ClockWatcher.IDLE_TOLERANCE_MS) {
log.info("We have been in standby mode for {} sec", missedMs / 1000);
listeners.forEach(listener -> listener.onAwakeFromStandby(missedMs));
}
}
lastSecondTick = currentTimeMillis;
}
lastSecondTick = currentTimeMillis;
}, 1, TimeUnit.SECONDS);
}
}
@ -84,10 +86,14 @@ public class ClockWatcher {
}
public void addListener(Listener listener) {
listeners.add(listener);
synchronized (listeners) {
listeners.add(listener);
}
}
public void removeListener(Listener listener) {
listeners.remove(listener);
synchronized (listeners) {
listeners.remove(listener);
}
}
}