net.thevpc.nuts.runtime.standalone.concurrent

Class NBulkheadCallBackendAsSemaphore

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NBulkheadCallBackendAsSemaphore

All Implemented Interfaces:

NBulkheadCallBackend

public class NBulkheadCallBackendAsSemaphore
extends Object
implements NBulkheadCallBackend

In-memory implementation of bulkhead backend using Java's Semaphore.

This implementation is fast and thread-safe but does not persist state across JVM restarts. For persistent bulkheads, use BulkheadBackendFileBasedImpl or BulkheadBackendRedisImpl.

This should be the default backend when no backend is explicitly configured.

Since:

0.8.7

Nested Class Summary

Nested classes/interfaces inherited from interface net.thevpc.nuts.concurrent.NBulkheadCallBackend

NBulkheadCallBackend.NBulkheadPermit

Constructor Summary

Constructors

Constructor and Description
NBulkheadCallBackendAsSemaphore()

Method Summary

Modifier and Type	Method and Description
int	cleanupExpired(String bulkheadId, NDuration expiryDuration)
NBulkheadMetrics	getMetrics(String bulkheadId)
void	release(NBulkheadCallBackend.NBulkheadPermit permit)
NOptional<NBulkheadCallBackend.NBulkheadPermit>	tryAcquire(String bulkheadId, int maxConcurrent)
NOptional<NBulkheadCallBackend.NBulkheadPermit>	tryAcquire(String bulkheadId, int maxConcurrent, NDuration timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

NBulkheadCallBackendAsSemaphore

public NBulkheadCallBackendAsSemaphore()

Method Detail

tryAcquire

public NOptional<NBulkheadCallBackend.NBulkheadPermit> tryAcquire(String bulkheadId,
                                                                  int maxConcurrent)

Specified by:

tryAcquire in interface NBulkheadCallBackend

tryAcquire

public NOptional<NBulkheadCallBackend.NBulkheadPermit> tryAcquire(String bulkheadId,
                                                                  int maxConcurrent,
                                                                  NDuration timeout)

Specified by:

tryAcquire in interface NBulkheadCallBackend

release

public void release(NBulkheadCallBackend.NBulkheadPermit permit)

Specified by:

release in interface NBulkheadCallBackend

getMetrics

public NBulkheadMetrics getMetrics(String bulkheadId)

Specified by:

getMetrics in interface NBulkheadCallBackend

cleanupExpired

public int cleanupExpired(String bulkheadId,
                          NDuration expiryDuration)

Specified by:

cleanupExpired in interface NBulkheadCallBackend