diff --git a/core/src/main/java/com/seibel/distanthorizons/core/util/threading/PriorityTaskPicker.java b/core/src/main/java/com/seibel/distanthorizons/core/util/threading/PriorityTaskPicker.java index a63872ce9..6f4fc72da 100644 --- a/core/src/main/java/com/seibel/distanthorizons/core/util/threading/PriorityTaskPicker.java +++ b/core/src/main/java/com/seibel/distanthorizons/core/util/threading/PriorityTaskPicker.java @@ -310,11 +310,7 @@ public class PriorityTaskPicker public void remove(@NotNull Runnable command) { this.taskQueue.removeIf(trackedRunnable -> trackedRunnable.command == command); } - public void runTask(@NotNull Runnable command) - { - this.threadPoolExecutor.execute(command); - this.runningTasksRef.getAndIncrement(); - } + public void runTask(@NotNull Runnable command) { this.threadPoolExecutor.execute(command); } public int getQueueSize() { return this.taskQueue.size(); } @@ -457,6 +453,8 @@ public class PriorityTaskPicker @Override public void run() { + this.executor.runningTasksRef.getAndIncrement(); + long startTime = System.nanoTime(); try {