Concurrency update

src/engine/gameManager/ForgeManager.java

@@ -29,7 +29,7 @@ public enum ForgeManager implements Runnable {
 
     private static final BlockingQueue<WorkOrder> forge = new DelayQueue<>();
     public static final AtomicInteger wordOrderCounter = new AtomicInteger(0);
-    public static final ConcurrentHashMap<NPC, ArrayList<WorkOrder>> vendorWorkOrderLookup = new ConcurrentHashMap<>();
+    public static final ConcurrentHashMap<NPC, CopyOnWriteArrayList<WorkOrder>> vendorWorkOrderLookup = new ConcurrentHashMap<>();
     public static final ConcurrentHashMap<Item, WorkOrder> itemWorkOrderLookup = new ConcurrentHashMap<>();
 
     @Override

src/engine/loot/WorkOrder.java

@@ -16,8 +16,8 @@ import java.time.Duration;
 import java.time.Instant;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
-import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.Delayed;
 import java.util.concurrent.TimeUnit;
 
@@ -39,7 +39,7 @@ public class WorkOrder implements Delayed {
     public long completionTime;
     public boolean runCompleted = false;
     public boolean runCanceled = false;
-    public ArrayList<Item> cooking = new ArrayList<>();
+    public CopyOnWriteArrayList<Item> cooking = new CopyOnWriteArrayList<>();
 
     public WorkOrder() {
 

src/engine/net/client/handlers/ItemProductionMsgHandler.java

@@ -164,6 +164,8 @@ public class ItemProductionMsgHandler extends AbstractClientMsgHandler {
 
             vendor.charItemManager.addItemToInventory(completedItem);
 
+            // Refresh the vendor inventory window
+
             ItemProductionMsg outMsg1 = new ItemProductionMsg(vendor.building, vendor, completedItem, mbEnums.ProductionActionType.DEPOSIT, true);
             DispatchMessage.dispatchMsgToInterestArea(vendor, outMsg1, mbEnums.DispatchChannel.SECONDARY, 700, false, false);
             ItemProductionMsg outMsg2 = new ItemProductionMsg(vendor.building, vendor, completedItem, mbEnums.ProductionActionType.CONFIRM_DEPOSIT, true);

src/engine/objects/NPC.java

@@ -35,6 +35,7 @@ import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
 import static engine.net.client.msg.ErrorPopupMsg.sendErrorPopup;
@@ -872,7 +873,7 @@ public class NPC extends AbstractCharacter {
         // If NPC is a vendor then configure ForgeManager support
 
         if (this.contract.isTrainer() == false)
-            ForgeManager.vendorWorkOrderLookup.computeIfAbsent(this, k -> new ArrayList<>());
+            ForgeManager.vendorWorkOrderLookup.computeIfAbsent(this, k -> new CopyOnWriteArrayList<>());
 
         this.symbol = this.contract.getIconID();
         this.modTypeTable = this.contract.getNPCModTypeTable();