Level Maintainer: don't queue jobs when all CPUs are busy. (#203)

GTNewHorizons · Mar 27, 2024 · f7d25c6 · f7d25c6
1 parent f175d70
commit f7d25c6
Showing 1 changed file with 16 additions and 3 deletions.
diff --git a/src/main/java/com/glodblock/github/common/tile/TileLevelMaintainer.java b/src/main/java/com/glodblock/github/common/tile/TileLevelMaintainer.java
@@ -26,6 +26,7 @@
 import appeng.api.networking.GridFlags;
 import appeng.api.networking.IGrid;
 import appeng.api.networking.IGridNode;
+import appeng.api.networking.crafting.ICraftingCPU;
 import appeng.api.networking.crafting.ICraftingGrid;
 import appeng.api.networking.crafting.ICraftingJob;
 import appeng.api.networking.crafting.ICraftingLink;
@@ -141,6 +142,17 @@ private TickRateModulation doWork() {
             final IGrid grid = getProxy().getGrid();
             final IItemList<IAEItemStack> inv = getProxy().getStorage().getItemInventory().getStorageList();
 
+            // Check there are available crafting CPUs before doing any work.
+            // This hopefully stops level maintainers busy-looping calculating
+            // crafting tasks that cannot be successfully submitted.
+            boolean allBusy = true;
+            for (final ICraftingCPU cpu : craftingGrid.getCpus()) {
+                if (!cpu.isBusy()) {
+                    allBusy = false;
+                    break;
+                }
+            }
+
             // Find a request that we can submit to the network.
             // If there is none, find the next request we can begin calculating.
             ICraftingJob jobToSubmit = null;
@@ -163,9 +175,10 @@ private TickRateModulation doWork() {
                     boolean shouldCraft = isCraftable && aeItem.getStackSize() < quantity;
                     if (isDone) requests.updateState(i, State.Idle);
                     if (!isCraftable) requests.updateState(i, State.Error);
-                    if (craftingGrid.canEmitFor(craftItem) || craftingGrid.isRequesting(craftItem)
-                            || !isDone
-                            || !shouldCraft)
+                    if (allBusy || !isDone
+                            || !shouldCraft
+                            || craftingGrid.canEmitFor(craftItem)
+                            || craftingGrid.isRequesting(craftItem))
                         continue;
                     // do crafting
                     Future<ICraftingJob> jobTask = requests.getJob(i);