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>, NElementDescribable, NElementRedescribable<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
T	call()
T	callBlocking()
T	callBlocking(NDuration timeout)
T	callOrElse(NDuration timeout, NCallable<T> fallback)
NElement	describe()
int	getActiveCalls()
int	getAvailableSlots()
int	getMaxConcurrent()
boolean	isFull()
void	reload()
NBulkheadCall<T>	setMaxConcurrent(int maxConcurrent)
NBulkheadCall<T>	setPermitExpiry(NDuration expiry)
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, redescribe

Constructor Detail

NBulkheadCallImpl

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

Method Detail

reload

public void reload()

setMaxConcurrent

public NBulkheadCall<T> setMaxConcurrent(int maxConcurrent)

Specified by:

setMaxConcurrent in interface NBulkheadCall<T>

setPermitExpiry

public NBulkheadCall<T> setPermitExpiry(NDuration expiry)

Specified by:

setPermitExpiry in interface NBulkheadCall<T>

getMaxConcurrent

public int getMaxConcurrent()

Specified by:

getMaxConcurrent in interface NBulkheadCall<T>

getActiveCalls

public int getActiveCalls()

Specified by:

getActiveCalls in interface NBulkheadCall<T>

getAvailableSlots

public int getAvailableSlots()

Specified by:

getAvailableSlots 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 NElementDescribable