Class Backpressure

java.lang.Object
com.quietterminal.neon.util.Backpressure
public final class Backpressure extends Object

  • Constructor Details

    • Backpressure

      public Backpressure(int maxConcurrent)

  • Method Details

    • tryAcquire

      public boolean tryAcquire()

    • release

      public void release()

    • availablePermits

      public int availablePermits()

    • isAtCapacity

      public boolean isAtCapacity()