diff --git a/src/main/java/me/cortex/voxy/common/thread/ServiceThreadPool.java b/src/main/java/me/cortex/voxy/common/thread/ServiceThreadPool.java index de847eeb..e8d198e3 100644 --- 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) {