boldsuck/haveno
1
0
Fork 0
mirror of https://github.com/boldsuck/haveno.git synced 2025-01-10 01:54:31 +00:00
Code Issues 1 Projects Releases Packages Wiki Activity Actions

shut down acquires trade lock until no delay so other threads can finish

Browse source
This commit is contained in:
woodser 2023-04-25 19:04:43 -04:00
parent 5545bcde38
commit 4cf6992113
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
core/src/main/java/haveno/core/trade/Trade.java
View file

@ -1148,9 +1148,15 @@ public abstract class Trade implements Tradable, Model {
public void onShutDownStarted() { public void onShutDownStarted() {
isShutDownStarted = true; isShutDownStarted = true;
if (wallet != null) log.info("{} {} preparing for shut down", getClass().getSimpleName(), getId()); if (wallet != null) log.info("{} {} preparing for shut down", getClass().getSimpleName(), getId());
// allow other threads to finish processing by acquiring trade locks until there's no delay
int maxAttempts = 10;
for (int i = 0; i < maxAttempts; i++) {
long startTimeMs = System.currentTimeMillis();
synchronized (this) { synchronized (this) {
synchronized (walletLock) { synchronized (walletLock) {
stopPolling(); // allow locks to release before stopping if (System.currentTimeMillis() - startTimeMs <= 10 || isShutDown) break;
}
} }
} }
} }