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>, net.thevpc.nuts.concurrent.NBulkheadCall<T>, net.thevpc.nuts.concurrent.NCallable<T>, net.thevpc.nuts.elem.NDescribable, net.thevpc.nuts.elem.NRedescribable<net.thevpc.nuts.concurrent.NCallable<T>>

public class NBulkheadCallImpl<T>
extends Object
implements net.thevpc.nuts.concurrent.NBulkheadCall<T>

Constructor Summary

Constructors

Constructor and Description
NBulkheadCallImpl(String id, net.thevpc.nuts.concurrent.NCallable<T> callable, net.thevpc.nuts.concurrent.NBulkheadCallStore store, net.thevpc.nuts.concurrent.NBulkheadCallBackend backend)

Method Summary

Modifier and Type	Method and Description
int	activeCalls()
int	availableSlots()
T	call()
T	callBlocking()
T	callBlocking(net.thevpc.nuts.time.NDuration timeout)
T	callOrElse(net.thevpc.nuts.time.NDuration timeout, net.thevpc.nuts.concurrent.NCallable<T> fallback)
net.thevpc.nuts.elem.NElement	describe()
boolean	isFull()
int	maxConcurrent()
net.thevpc.nuts.concurrent.NBulkheadCall<T>	maxConcurrent(int maxConcurrent)
net.thevpc.nuts.concurrent.NBulkheadCall<T>	permitExpiry(net.thevpc.nuts.time.NDuration expiry)
void	reload()
net.thevpc.nuts.util.NOptional<T>	tryCall()
T	tryCallOrElse(net.thevpc.nuts.concurrent.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,
                         net.thevpc.nuts.concurrent.NCallable<T> callable,
                         net.thevpc.nuts.concurrent.NBulkheadCallStore store,
                         net.thevpc.nuts.concurrent.NBulkheadCallBackend backend)

Method Detail

reload

public void reload()

maxConcurrent

public net.thevpc.nuts.concurrent.NBulkheadCall<T> maxConcurrent(int maxConcurrent)

Specified by:

maxConcurrent in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

permitExpiry

public net.thevpc.nuts.concurrent.NBulkheadCall<T> permitExpiry(net.thevpc.nuts.time.NDuration expiry)

Specified by:

permitExpiry in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

maxConcurrent

public int maxConcurrent()

Specified by:

maxConcurrent in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

activeCalls

public int activeCalls()

Specified by:

activeCalls in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

availableSlots

public int availableSlots()

Specified by:

availableSlots in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

isFull

public boolean isFull()

Specified by:

isFull in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

tryCall

public net.thevpc.nuts.util.NOptional<T> tryCall()

Specified by:

tryCall in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

tryCallOrElse

public T tryCallOrElse(net.thevpc.nuts.concurrent.NCallable<T> fallback)

Specified by:

tryCallOrElse in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

callBlocking

public T callBlocking()
               throws net.thevpc.nuts.concurrent.NInterruptedException

Specified by:

callBlocking in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

Throws:

net.thevpc.nuts.concurrent.NInterruptedException

call

public T call()

Specified by:

call in interface Callable<T>

Specified by:

call in interface net.thevpc.nuts.concurrent.NCallable<T>

callBlocking

public T callBlocking(net.thevpc.nuts.time.NDuration timeout)
               throws net.thevpc.nuts.concurrent.NInterruptedException

Specified by:

callBlocking in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

Throws:

net.thevpc.nuts.concurrent.NInterruptedException

callOrElse

public T callOrElse(net.thevpc.nuts.time.NDuration timeout,
                    net.thevpc.nuts.concurrent.NCallable<T> fallback)
             throws net.thevpc.nuts.concurrent.NInterruptedException

Specified by:

callOrElse in interface net.thevpc.nuts.concurrent.NBulkheadCall<T>

Throws:

net.thevpc.nuts.concurrent.NInterruptedException

describe

public net.thevpc.nuts.elem.NElement describe()

Specified by:

describe in interface net.thevpc.nuts.elem.NDescribable