From ea785f79b8e4b813c585c888201dd9af5ccb60e8 Mon Sep 17 00:00:00 2001 From: CalDescent Date: Fri, 4 Mar 2022 19:02:30 +0000 Subject: [PATCH] Removed unnecessary synchronization --- .../controller/OnlineAccountsManager.java | 28 +++++++++---------- 1 file changed, 13 insertions(+), 15 deletions(-) diff --git a/src/main/java/org/qortal/controller/OnlineAccountsManager.java b/src/main/java/org/qortal/controller/OnlineAccountsManager.java index 64855974..038c065e 100644 --- a/src/main/java/org/qortal/controller/OnlineAccountsManager.java +++ b/src/main/java/org/qortal/controller/OnlineAccountsManager.java @@ -474,24 +474,22 @@ public class OnlineAccountsManager extends Thread { LOGGER.debug(String.format("Received %d online accounts from %s", peersOnlineAccounts.size(), peer)); int importCount = 0; - - synchronized(onlineAccountsImportQueue) { - // Add any online accounts to the queue that aren't already present - for (OnlineAccountData onlineAccountData : peersOnlineAccounts) { - // Do we already know about this online account data? - if (onlineAccounts.contains(onlineAccountData)) { - continue; - } + // Add any online accounts to the queue that aren't already present + for (OnlineAccountData onlineAccountData : peersOnlineAccounts) { - // Is it already in the import queue? - if (onlineAccountsImportQueue.contains(onlineAccountData)) { - continue; - } - - onlineAccountsImportQueue.add(onlineAccountData); - importCount++; + // Do we already know about this online account data? + if (onlineAccounts.contains(onlineAccountData)) { + continue; } + + // Is it already in the import queue? + if (onlineAccountsImportQueue.contains(onlineAccountData)) { + continue; + } + + onlineAccountsImportQueue.add(onlineAccountData); + importCount++; } LOGGER.debug(String.format("Added %d online accounts to queue", importCount));