limiter fixup

Opetushallitus · Dec 16, 2024 · eb593f9 · eb593f9
1 parent a070c4f
commit eb593f9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/fi/vm/sade/valinta/kooste/valintalaskenta/actor/ConcurrencyLimiter.java b/src/main/java/fi/vm/sade/valinta/kooste/valintalaskenta/actor/ConcurrencyLimiter.java
@@ -63,8 +63,8 @@ public void setMaxPermits(int newPermits) {
       LOG.info("Lisätään vaiheen " + this.nimi + " limitteriin " + dPermits + " permittiä.");
       this.semaphore.release(dPermits);
     } else {
-      LOG.info("Vähennetään vaiheen " + this.nimi + " limitteristä " + dPermits + " permittiä.");
-      this.executor.submit(() -> this.semaphore.acquireUninterruptibly(dPermits));
+      LOG.info("Vähennetään vaiheen " + this.nimi + " limitteristä " + -dPermits + " permittiä.");
+      this.executor.submit(() -> this.semaphore.acquireUninterruptibly(-dPermits));
     }
   }