final class AsyncSemaphore
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
(package private) class |
AsyncSemaphore.Permit |
Modifier and Type | Field and Description |
---|---|
private int |
permits |
private java.util.Queue<java.util.concurrent.CompletableFuture<AsyncSemaphore.Permit>> |
queue |
private AsyncSemaphore.Permit |
singletonPermit |
Constructor and Description |
---|
AsyncSemaphore(int permits) |
Modifier and Type | Method and Description |
---|---|
(package private) java.util.concurrent.CompletionStage<AsyncSemaphore.Permit> |
acquire(java.time.Duration timeout) |
private final java.util.Queue<java.util.concurrent.CompletableFuture<AsyncSemaphore.Permit>> queue
private final AsyncSemaphore.Permit singletonPermit
private volatile int permits
java.util.concurrent.CompletionStage<AsyncSemaphore.Permit> acquire(java.time.Duration timeout)