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 index c66b585e5..cb5a0cade 100644 --- 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)); } }