nihilist/haveno
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix possible concurrent modification exception

Browse Source
This commit is contained in:
woodser 2022-08-08 15:49:07 -04:00
parent cebdef31c0
commit 4901808844
1 changed files with 15 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
core/src/main/java/bisq/core/trade/TradeManager.java
View File

@ -91,6 +91,7 @@ import javafx.collections.ObservableList;
import org.bouncycastle.crypto.params.KeyParameter; import org.bouncycastle.crypto.params.KeyParameter;
import org.fxmisc.easybind.EasyBind; import org.fxmisc.easybind.EasyBind;
import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;
@ -881,24 +882,22 @@ public class TradeManager implements PersistedDataHost, DecryptedDirectMessageLi
} }
private void updateTradePeriodState() { private void updateTradePeriodState() {
UserThread.execute(() -> { // prevent concurrent modification error for (Trade trade : new ArrayList<Trade>(tradableList.getList())) {
getObservableList().forEach(trade -> { if (!trade.isPayoutPublished()) {
if (!trade.isPayoutPublished()) { Date maxTradePeriodDate = trade.getMaxTradePeriodDate();
Date maxTradePeriodDate = trade.getMaxTradePeriodDate(); Date halfTradePeriodDate = trade.getHalfTradePeriodDate();
Date halfTradePeriodDate = trade.getHalfTradePeriodDate(); if (maxTradePeriodDate != null && halfTradePeriodDate != null) {
if (maxTradePeriodDate != null && halfTradePeriodDate != null) { Date now = new Date();
Date now = new Date(); if (now.after(maxTradePeriodDate)) {
if (now.after(maxTradePeriodDate)) { trade.setPeriodState(Trade.TradePeriodState.TRADE_PERIOD_OVER);
trade.setPeriodState(Trade.TradePeriodState.TRADE_PERIOD_OVER); requestPersistence();
requestPersistence(); } else if (now.after(halfTradePeriodDate)) {
} else if (now.after(halfTradePeriodDate)) { trade.setPeriodState(Trade.TradePeriodState.SECOND_HALF);
trade.setPeriodState(Trade.TradePeriodState.SECOND_HALF); requestPersistence();
requestPersistence();
}
} }
} }
}); }
}); }
} }