net.thevpc.nuts.runtime.standalone.concurrent

Class NBulkheadCallImpl<T>

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NBulkheadCallImpl<T>

All Implemented Interfaces:

Callable<T>, NBulkheadCall<T>, NCallable<T>, NDescribable, NRedescribable<NCallable<T>>

public class NBulkheadCallImpl<T>
extends Object
implements NBulkheadCall<T>

Constructor Summary

Constructors

Constructor and Description
NBulkheadCallImpl(String id, NCallable<T> callable, NBulkheadCallStore store, NBulkheadCallBackend backend)

Method Summary

Modifier and Type	Method and Description
int	activeCalls()
int	availableSlots()
T	call()
T	callBlocking()
T	callBlocking(NDuration timeout)
T	callOrElse(NDuration timeout, NCallable<T> fallback)
NElement	describe()
boolean	isFull()
int	maxConcurrent()
NBulkheadCall<T>	maxConcurrent(int maxConcurrent)
NBulkheadCall<T>	permitExpiry(NDuration expiry)
void	reload()
NOptional<T>	tryCall()
T	tryCallOrElse(NCallable<T> fallback)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.thevpc.nuts.concurrent.NBulkheadCall

of, of

Methods inherited from interface net.thevpc.nuts.concurrent.NCallable

of, withDescription

Constructor Detail

NBulkheadCallImpl

public NBulkheadCallImpl(String id,
                         NCallable<T> callable,
                         NBulkheadCallStore store,
                         NBulkheadCallBackend backend)

Method Detail

reload

public void reload()

maxConcurrent

public NBulkheadCall<T> maxConcurrent(int maxConcurrent)

Specified by:

maxConcurrent in interface NBulkheadCall<T>

permitExpiry

public NBulkheadCall<T> permitExpiry(NDuration expiry)

Specified by:

permitExpiry in interface NBulkheadCall<T>

maxConcurrent

public int maxConcurrent()

Specified by:

maxConcurrent in interface NBulkheadCall<T>

activeCalls

public int activeCalls()

Specified by:

activeCalls in interface NBulkheadCall<T>

availableSlots

public int availableSlots()

Specified by:

availableSlots in interface NBulkheadCall<T>

isFull

public boolean isFull()

Specified by:

isFull in interface NBulkheadCall<T>

tryCall

public NOptional<T> tryCall()

Specified by:

tryCall in interface NBulkheadCall<T>

tryCallOrElse

public T tryCallOrElse(NCallable<T> fallback)

Specified by:

tryCallOrElse in interface NBulkheadCall<T>

callBlocking

public T callBlocking()
               throws NInterruptedException

Specified by:

callBlocking in interface NBulkheadCall<T>

Throws:

NInterruptedException

call

public T call()

Specified by:

call in interface Callable<T>

Specified by:

call in interface NCallable<T>

callBlocking

public T callBlocking(NDuration timeout)
               throws NInterruptedException

Specified by:

callBlocking in interface NBulkheadCall<T>

Throws:

NInterruptedException

callOrElse

public T callOrElse(NDuration timeout,
                    NCallable<T> fallback)
             throws NInterruptedException

Specified by:

callOrElse in interface NBulkheadCall<T>

Throws:

NInterruptedException

describe

public NElement describe()

Specified by:

describe in interface NDescribable