org.xbill.DNS

Class AsyncSemaphore

java.lang.Object

org.xbill.DNS.AsyncSemaphore

final class AsyncSemaphore
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	AsyncSemaphore.Permit

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
AsyncSemaphore(int permits)

Method Summary

Modifier and Type	Method and Description
(package private) java.util.concurrent.CompletionStage<AsyncSemaphore.Permit>	acquire(java.time.Duration timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

queue

private final java.util.Queue<java.util.concurrent.CompletableFuture<AsyncSemaphore.Permit>> queue

singletonPermit

private final AsyncSemaphore.Permit singletonPermit

permits

private volatile int permits

Constructor Detail

AsyncSemaphore

AsyncSemaphore(int permits)

Method Detail

acquire

java.util.concurrent.CompletionStage<AsyncSemaphore.Permit> acquire(java.time.Duration timeout)