Class AutoSemaphoreImpl

java.lang.Object

java.util.concurrent.Semaphore

org.tquadrat.foundation.lang.internal.AutoSemaphoreImpl

All Implemented Interfaces:

Serializable, AutoSemaphore

@ClassVersion(sourceVersion="$Id: AutoSemaphoreImpl.java 1258 2026-06-04 18:33:06Z tquadrat $")
@API(status=STABLE,
     since="0.4.8")
public final class AutoSemaphoreImpl
extends Semaphore
implements AutoSemaphore

The implementation of AutoSemaphore. At the same time, this class extends Semaphore.

Author:

Thomas Thrien (thomas.thrien@tquadrat.org)

Version:

$Id: AutoSemaphoreImpl.java 1258 2026-06-04 18:33:06Z tquadrat $

Since:

0.25.2

See Also:

• Serialized Form

UML Diagram

⁠

UML Diagram for "org.tquadrat.foundation.lang.internal.AutoSemaphoreImpl"

⁠

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	AutoSemaphoreImpl.TokenImpl	The implementation of AutoSemaphore.Token.

Nested classes/interfaces inherited from interface AutoSemaphore

AutoSemaphore.Token

Constructor Summary

Constructors

Constructor	Description
AutoSemaphoreImpl(int permits)	Creates an AutoSemaphoreImpl instance with the given number of permits and non-fair fairness setting.
AutoSemaphoreImpl(int permits, boolean fair)	Creates an AutoSemaphoreImpl instance with the given number of permits and the given fairness setting.

Method Summary

Modifier and Type	Method	Description
final AutoSemaphore.Token	acquireToken(int permits)	Acquires the given number of permits from this semaphore, blocking until all are available, or the thread is interrupted, and returns a token object that is used for try-with-resources.
final AutoSemaphore.Token	acquireTokenUninterruptibly(int permits)	Acquires the given number of permits from this semaphore, blocking until all are available, and returns a token object that is used for try-with-resources.
final Semaphore	getSemaphore()	Returns a reference to the raw semaphore.

Methods inherited from class Semaphore

acquire, acquire, acquireUninterruptibly, acquireUninterruptibly, availablePermits, drainPermits, getQueuedThreads, getQueueLength, hasQueuedThreads, isFair, reducePermits, release, release, toString, tryAcquire, tryAcquire, tryAcquire, tryAcquire

Methods inherited from class Object

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

Methods inherited from interface AutoSemaphore

acquireToken, acquireTokenUninterruptibly

Constructor Details

AutoSemaphoreImpl

public AutoSemaphoreImpl(int permits)

Creates an AutoSemaphoreImpl instance with the given number of permits and non-fair fairness setting.

Parameters:

permits - The initial number of permits available. This value may be negative, in which case releases must occur before any acquires will be granted.

AutoSemaphoreImpl

public AutoSemaphoreImpl(int permits,
 boolean fair)

Creates an AutoSemaphoreImpl instance with the given number of permits and the given fairness setting.

Parameters:

permits - The initial number of permits available. This value may be negative, in which case releases must occur before any acquires will be granted.

fair - true if this semaphore will guarantee first-in first-out granting of permits under contention, else false.

Method Details

acquireToken

public final AutoSemaphore.Token acquireToken(int permits)
                                       throws InterruptedException,
IllegalArgumentException

Acquires the given number of permits from this semaphore, blocking until all are available, or the thread is interrupted, and returns a token object that is used for try-with-resources.

Acquires the given number of permits, if they are available, and returns immediately, reducing the number of available permits by the given amount. This method atomically acquires the permits all at once.

If insufficient permits are available then the current thread becomes disabled for thread scheduling purposes and lies dormant until one of two things happens:

• Some other thread invokes one of the release() methods for this semaphore and the current thread is next to be assigned permits and the number of available permits satisfies this request; or
• Some other thread interrupts the current thread.

If the current thread:

• has its interrupted status set on entry to this method; or
• is interrupted while waiting for a permit,

then an InterruptedException is thrown and the current thread's interrupted status is cleared. Any permits that were to be assigned to this thread are instead assigned to other threads trying to acquire permits, as if permits had been made available by a call to release().

Specified by:

acquireToken in interface AutoSemaphore

Parameters:

permits - The number of permits to acquire.

Returns:

The token.

Throws:

InterruptedException - The current thread is interrupted.

IllegalArgumentException - The given number of permits to acquire is negative.

acquireTokenUninterruptibly

public final AutoSemaphore.Token acquireTokenUninterruptibly(int permits)
                                                      throws IllegalArgumentException

Acquires the given number of permits from this semaphore, blocking until all are available, and returns a token object that is used for try-with-resources.

Acquires the given number of permits, if they are available, and returns immediately, reducing the number of available permits by the given amount. This method atomically acquires the permits all at once.

If insufficient permits are available then the current thread becomes disabled for thread scheduling purposes and lies dormant until some other thread invokes one of the release() methods for this semaphore and the current thread is next to be assigned permits and the number of available permits satisfies this request.

If the current thread is interrupted while waiting for permits then it will continue to wait and its position in the queue is not affected. When the thread does return from this method its interrupt status will be set.

Specified by:

acquireTokenUninterruptibly in interface AutoSemaphore

Parameters:

permits - The number of permits to acquire.

Returns:

The token.

Throws:

IllegalArgumentException - The given number of permits to acquire is negative.

getSemaphore

public final Semaphore getSemaphore()

Returns a reference to the raw semaphore.

Specified by:

getSemaphore in interface AutoSemaphore

Returns:

The semaphore.