Package io.grpc.alts.internal
Class AsyncSemaphore
java.lang.Object
io.grpc.alts.internal.AsyncSemaphore
Provides a semaphore primitive, without blocking waiting on permits.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
lock
-
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()
-