Package | Description |
---|---|
org.xbill.DNS |
Modifier and Type | Field and Description |
---|---|
private AsyncSemaphore.Permit |
AsyncSemaphore.singletonPermit |
Modifier and Type | Field and Description |
---|---|
private java.util.Queue<java.util.concurrent.CompletableFuture<AsyncSemaphore.Permit>> |
AsyncSemaphore.queue |
Modifier and Type | Method and Description |
---|---|
(package private) java.util.concurrent.CompletionStage<AsyncSemaphore.Permit> |
AsyncSemaphore.acquire(java.time.Duration timeout) |
Modifier and Type | Method and Description |
---|---|
private java.util.concurrent.CompletionStage<Message> |
DohResolver.sendAsync11WithConcurrentRequestPermit(Message query,
java.util.concurrent.Executor executor,
long startTime,
java.lang.Object requestBuilder,
AsyncSemaphore.Permit initialRequestPermit,
boolean isInitialRequest,
AsyncSemaphore.Permit maxConcurrentRequestPermit) |
private java.util.concurrent.CompletionStage<Message> |
DohResolver.sendAsync11WithInitialRequestPermit(Message query,
java.util.concurrent.Executor executor,
long startTime,
java.lang.Object requestBuilder,
AsyncSemaphore.Permit initialRequestPermit) |