Attempt to fix stupid concurrency issue by force stealing jobs

2025-04-30 23:25:16 +10:00
parent b526d5a51a
commit dd46c43c73
1 changed files with 3 additions and 1 deletions
--- a/src/main/java/me/cortex/voxy/common/thread/ServiceThreadPool.java
+++ b/src/main/java/me/cortex/voxy/common/thread/ServiceThreadPool.java
@@ -129,7 +129,9 @@ public class ServiceThreadPool {

    void steal(ServiceSlice service, int count) {
        this.totalJobWeight.addAndGet(-(service.weightPerJob*(long)count));
-        this.jobCounter.acquireUninterruptibly(count);
+        for (int i = 0; i < count; i++) {
+            this.jobCounter.acquireUninterruptibly();
+        }
    }

    private void worker(int threadId) {