Class AsyncSemaphore

java.lang.Object
io.grpc.alts.internal.AsyncSemaphore

final class AsyncSemaphore extends Object
Provides a semaphore primitive, without blocking waiting on permits.
  • Field Details

    • lock

      private final Object lock
    • queue

      private final Queue<io.netty.channel.ChannelPromise> queue
    • permits

      private int permits
  • Constructor Details

    • AsyncSemaphore

      public AsyncSemaphore(int permits)
  • Method Details

    • acquire

      public io.netty.channel.ChannelFuture acquire(io.netty.channel.ChannelHandlerContext ctx)
    • release

      public void release()