net.thevpc.nuts.runtime.standalone.concurrent

Class NConcurrentImpl

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NConcurrentImpl

All Implemented Interfaces:

net.thevpc.nuts.concurrent.NConcurrent, net.thevpc.nuts.spi.NComponent

public class NConcurrentImpl
extends Object
implements net.thevpc.nuts.concurrent.NConcurrent

Constructor Summary

Constructors

Constructor and Description
NConcurrentImpl()

Method Summary

Modifier and Type	Method and Description
net.thevpc.nuts.concurrent.NBulkheadCallFactory	bulkheadCallFactory()
net.thevpc.nuts.concurrent.NConcurrent	bulkheadCallFactory(net.thevpc.nuts.concurrent.NBulkheadCallFactory bulkheadCallFactory)
<T> net.thevpc.nuts.concurrent.NCachedValue<T>	cachedValue(String id, Supplier<T> supplier)
<T> net.thevpc.nuts.concurrent.NCachedValue<T>	cachedValue(Supplier<T> supplier)
net.thevpc.nuts.concurrent.NCachedValueFactory	cachedValueFactory()
net.thevpc.nuts.concurrent.NConcurrent	cachedValueFactory(net.thevpc.nuts.concurrent.NCachedValueFactory cachedValueFactory)
<T> net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>	circuitBreakerCall(net.thevpc.nuts.concurrent.NCallable<T> callable)
<T> net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>	circuitBreakerCall(String id, net.thevpc.nuts.concurrent.NCallable<T> callable)
net.thevpc.nuts.concurrent.NCircuitBreakerCallFactory	circuitBreakerCallFactory()
net.thevpc.nuts.concurrent.NConcurrent	circuitBreakerCallFactory(net.thevpc.nuts.concurrent.NCircuitBreakerCallFactory circuitBreakerCallFactory)
net.thevpc.nuts.concurrent.NBulkheadCallFactory	defaultBulkheadCallFactory()
net.thevpc.nuts.concurrent.NCachedValueFactory	defaultCachedValueFactory()
net.thevpc.nuts.concurrent.NCircuitBreakerCallFactory	defaultCircuitBreakerCallFactory()
net.thevpc.nuts.concurrent.NOnceValueFactory	defaultOnceValueFactory()
net.thevpc.nuts.concurrent.NRateLimitValueFactory	defaultRateLimitValueFactory()
net.thevpc.nuts.concurrent.NRetryCallFactory	defaultRetryCallFactory()
net.thevpc.nuts.concurrent.NSagaCallableFactory	defaultSagaFactory()
net.thevpc.nuts.concurrent.NWorkBalancerFactory	defaultWorkBalancerFactory()
ExecutorService	executorService()
net.thevpc.nuts.concurrent.NBulkheadCallFactory	memoryBulkheadCallFactory()
net.thevpc.nuts.concurrent.NCachedValueFactory	memoryCachedValueFactory()
net.thevpc.nuts.concurrent.NCircuitBreakerCallFactory	memoryCircuitBreakerCallFactory()
net.thevpc.nuts.concurrent.NOnceValueFactory	memoryOnceValueFactory()
net.thevpc.nuts.concurrent.NRateLimitValueFactory	memoryRateLimitValueFactory()
net.thevpc.nuts.concurrent.NRetryCallFactory	memoryRetryCallFactory()
net.thevpc.nuts.concurrent.NSagaCallableFactory	memorySagaFactory()
net.thevpc.nuts.concurrent.NWorkBalancerFactory	memoryWorkBalancerFactory()
<T> net.thevpc.nuts.concurrent.NOnceValue<T>	onceValue(String id, Supplier<T> supplier)
<T> net.thevpc.nuts.concurrent.NOnceValue<T>	onceValue(Supplier<T> supplier)
net.thevpc.nuts.concurrent.NOnceValueFactory	onceValueFactory()
net.thevpc.nuts.concurrent.NConcurrent	onceValueFactory(net.thevpc.nuts.concurrent.NOnceValueFactory onceValueFactory)
net.thevpc.nuts.concurrent.NRateLimitValueFactory	rateLimitValueFactory()
net.thevpc.nuts.concurrent.NConcurrent	rateLimitValueFactory(net.thevpc.nuts.concurrent.NRateLimitValueFactory factory)
<T> net.thevpc.nuts.concurrent.NRetryCall<T>	retryCall(net.thevpc.nuts.concurrent.NCallable<T> callable)
<T> net.thevpc.nuts.concurrent.NRetryCall<T>	retryCall(String id, net.thevpc.nuts.concurrent.NCallable<T> callable)
net.thevpc.nuts.concurrent.NRetryCallFactory	retryCallFactory()
IntFunction<net.thevpc.nuts.time.NDuration>	retryFixedPeriod(net.thevpc.nuts.time.NDuration period)
IntFunction<net.thevpc.nuts.time.NDuration>	retryFixedPeriods(net.thevpc.nuts.time.NDuration... periods)
IntFunction<net.thevpc.nuts.time.NDuration>	retryMultipliedPeriod(net.thevpc.nuts.time.NDuration base, double multiplier)
net.thevpc.nuts.concurrent.NSagaCallableBuilder	sagaCallBuilder()
net.thevpc.nuts.concurrent.NSagaCallableFactory	sagaFactory()
net.thevpc.nuts.concurrent.NConcurrent	setRetryCallFactory(net.thevpc.nuts.concurrent.NRetryCallFactory retryCallFactory)
net.thevpc.nuts.concurrent.NConcurrent	sleep(Duration durationMillis)
net.thevpc.nuts.concurrent.NConcurrent	sleep(long durationMillis)
net.thevpc.nuts.concurrent.NConcurrent	sleep(net.thevpc.nuts.time.NDuration durationMillis)
net.thevpc.nuts.concurrent.NTaskSet	taskSet()
net.thevpc.nuts.concurrent.NConcurrent	workBalancerCallFactory(net.thevpc.nuts.concurrent.NWorkBalancerFactory workBalancerCallFactory)
net.thevpc.nuts.concurrent.NWorkBalancerFactory	workBalancerFactory()

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.NConcurrent

of

Constructor Detail

NConcurrentImpl

public NConcurrentImpl()

Method Detail

cachedValueFactory

public net.thevpc.nuts.concurrent.NConcurrent cachedValueFactory(net.thevpc.nuts.concurrent.NCachedValueFactory cachedValueFactory)

Specified by:

cachedValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

memoryCachedValueFactory

public net.thevpc.nuts.concurrent.NCachedValueFactory memoryCachedValueFactory()

Specified by:

memoryCachedValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

defaultCachedValueFactory

public net.thevpc.nuts.concurrent.NCachedValueFactory defaultCachedValueFactory()

Specified by:

defaultCachedValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

cachedValueFactory

public net.thevpc.nuts.concurrent.NCachedValueFactory cachedValueFactory()

Specified by:

cachedValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

setRetryCallFactory

public net.thevpc.nuts.concurrent.NConcurrent setRetryCallFactory(net.thevpc.nuts.concurrent.NRetryCallFactory retryCallFactory)

Specified by:

setRetryCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

memoryRetryCallFactory

public net.thevpc.nuts.concurrent.NRetryCallFactory memoryRetryCallFactory()

Specified by:

memoryRetryCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

defaultRetryCallFactory

public net.thevpc.nuts.concurrent.NRetryCallFactory defaultRetryCallFactory()

Specified by:

defaultRetryCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

retryCallFactory

public net.thevpc.nuts.concurrent.NRetryCallFactory retryCallFactory()

Specified by:

retryCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

onceValueFactory

public net.thevpc.nuts.concurrent.NConcurrent onceValueFactory(net.thevpc.nuts.concurrent.NOnceValueFactory onceValueFactory)

Specified by:

onceValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

memoryOnceValueFactory

public net.thevpc.nuts.concurrent.NOnceValueFactory memoryOnceValueFactory()

Specified by:

memoryOnceValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

defaultOnceValueFactory

public net.thevpc.nuts.concurrent.NOnceValueFactory defaultOnceValueFactory()

Specified by:

defaultOnceValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

onceValueFactory

public net.thevpc.nuts.concurrent.NOnceValueFactory onceValueFactory()

Specified by:

onceValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

defaultRateLimitValueFactory

public net.thevpc.nuts.concurrent.NRateLimitValueFactory defaultRateLimitValueFactory()

Specified by:

defaultRateLimitValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

defaultSagaFactory

public net.thevpc.nuts.concurrent.NSagaCallableFactory defaultSagaFactory()

Specified by:

defaultSagaFactory in interface net.thevpc.nuts.concurrent.NConcurrent

memorySagaFactory

public net.thevpc.nuts.concurrent.NSagaCallableFactory memorySagaFactory()

Specified by:

memorySagaFactory in interface net.thevpc.nuts.concurrent.NConcurrent

memoryRateLimitValueFactory

public net.thevpc.nuts.concurrent.NRateLimitValueFactory memoryRateLimitValueFactory()

Specified by:

memoryRateLimitValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

rateLimitValueFactory

public net.thevpc.nuts.concurrent.NConcurrent rateLimitValueFactory(net.thevpc.nuts.concurrent.NRateLimitValueFactory factory)

Specified by:

rateLimitValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

rateLimitValueFactory

public net.thevpc.nuts.concurrent.NRateLimitValueFactory rateLimitValueFactory()

Specified by:

rateLimitValueFactory in interface net.thevpc.nuts.concurrent.NConcurrent

sagaFactory

public net.thevpc.nuts.concurrent.NSagaCallableFactory sagaFactory()

Specified by:

sagaFactory in interface net.thevpc.nuts.concurrent.NConcurrent

cachedValue

public <T> net.thevpc.nuts.concurrent.NCachedValue<T> cachedValue(Supplier<T> supplier)

Specified by:

cachedValue in interface net.thevpc.nuts.concurrent.NConcurrent

onceValue

public <T> net.thevpc.nuts.concurrent.NOnceValue<T> onceValue(Supplier<T> supplier)

Specified by:

onceValue in interface net.thevpc.nuts.concurrent.NConcurrent

cachedValue

public <T> net.thevpc.nuts.concurrent.NCachedValue<T> cachedValue(String id,
                                                                  Supplier<T> supplier)

Specified by:

cachedValue in interface net.thevpc.nuts.concurrent.NConcurrent

onceValue

public <T> net.thevpc.nuts.concurrent.NOnceValue<T> onceValue(String id,
                                                              Supplier<T> supplier)

Specified by:

onceValue in interface net.thevpc.nuts.concurrent.NConcurrent

retryCall

public <T> net.thevpc.nuts.concurrent.NRetryCall<T> retryCall(String id,
                                                              net.thevpc.nuts.concurrent.NCallable<T> callable)

Specified by:

retryCall in interface net.thevpc.nuts.concurrent.NConcurrent

retryCall

public <T> net.thevpc.nuts.concurrent.NRetryCall<T> retryCall(net.thevpc.nuts.concurrent.NCallable<T> callable)

Specified by:

retryCall in interface net.thevpc.nuts.concurrent.NConcurrent

circuitBreakerCall

public <T> net.thevpc.nuts.concurrent.NCircuitBreakerCall<T> circuitBreakerCall(net.thevpc.nuts.concurrent.NCallable<T> callable)

Specified by:

circuitBreakerCall in interface net.thevpc.nuts.concurrent.NConcurrent

circuitBreakerCall

public <T> net.thevpc.nuts.concurrent.NCircuitBreakerCall<T> circuitBreakerCall(String id,
                                                                                net.thevpc.nuts.concurrent.NCallable<T> callable)

Specified by:

circuitBreakerCall in interface net.thevpc.nuts.concurrent.NConcurrent

circuitBreakerCallFactory

public net.thevpc.nuts.concurrent.NConcurrent circuitBreakerCallFactory(net.thevpc.nuts.concurrent.NCircuitBreakerCallFactory circuitBreakerCallFactory)

Specified by:

circuitBreakerCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

memoryCircuitBreakerCallFactory

public net.thevpc.nuts.concurrent.NCircuitBreakerCallFactory memoryCircuitBreakerCallFactory()

Specified by:

memoryCircuitBreakerCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

defaultCircuitBreakerCallFactory

public net.thevpc.nuts.concurrent.NCircuitBreakerCallFactory defaultCircuitBreakerCallFactory()

Specified by:

defaultCircuitBreakerCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

circuitBreakerCallFactory

public net.thevpc.nuts.concurrent.NCircuitBreakerCallFactory circuitBreakerCallFactory()

Specified by:

circuitBreakerCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

executorService

public ExecutorService executorService()

Specified by:

executorService in interface net.thevpc.nuts.concurrent.NConcurrent

sagaCallBuilder

public net.thevpc.nuts.concurrent.NSagaCallableBuilder sagaCallBuilder()

Specified by:

sagaCallBuilder in interface net.thevpc.nuts.concurrent.NConcurrent

defaultWorkBalancerFactory

public net.thevpc.nuts.concurrent.NWorkBalancerFactory defaultWorkBalancerFactory()

Specified by:

defaultWorkBalancerFactory in interface net.thevpc.nuts.concurrent.NConcurrent

memoryWorkBalancerFactory

public net.thevpc.nuts.concurrent.NWorkBalancerFactory memoryWorkBalancerFactory()

Specified by:

memoryWorkBalancerFactory in interface net.thevpc.nuts.concurrent.NConcurrent

workBalancerFactory

public net.thevpc.nuts.concurrent.NWorkBalancerFactory workBalancerFactory()

Specified by:

workBalancerFactory in interface net.thevpc.nuts.concurrent.NConcurrent

workBalancerCallFactory

public net.thevpc.nuts.concurrent.NConcurrent workBalancerCallFactory(net.thevpc.nuts.concurrent.NWorkBalancerFactory workBalancerCallFactory)

Specified by:

workBalancerCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

sleep

public net.thevpc.nuts.concurrent.NConcurrent sleep(net.thevpc.nuts.time.NDuration durationMillis)
                                             throws net.thevpc.nuts.concurrent.NInterruptedException

Specified by:

sleep in interface net.thevpc.nuts.concurrent.NConcurrent

Throws:

net.thevpc.nuts.concurrent.NInterruptedException

sleep

public net.thevpc.nuts.concurrent.NConcurrent sleep(Duration durationMillis)
                                             throws net.thevpc.nuts.concurrent.NInterruptedException

Specified by:

sleep in interface net.thevpc.nuts.concurrent.NConcurrent

Throws:

net.thevpc.nuts.concurrent.NInterruptedException

sleep

public net.thevpc.nuts.concurrent.NConcurrent sleep(long durationMillis)
                                             throws net.thevpc.nuts.concurrent.NInterruptedException

Specified by:

sleep in interface net.thevpc.nuts.concurrent.NConcurrent

Throws:

net.thevpc.nuts.concurrent.NInterruptedException

taskSet

public net.thevpc.nuts.concurrent.NTaskSet taskSet()

Specified by:

taskSet in interface net.thevpc.nuts.concurrent.NConcurrent

retryFixedPeriod

public IntFunction<net.thevpc.nuts.time.NDuration> retryFixedPeriod(net.thevpc.nuts.time.NDuration period)

Specified by:

retryFixedPeriod in interface net.thevpc.nuts.concurrent.NConcurrent

retryFixedPeriods

public IntFunction<net.thevpc.nuts.time.NDuration> retryFixedPeriods(net.thevpc.nuts.time.NDuration... periods)

Specified by:

retryFixedPeriods in interface net.thevpc.nuts.concurrent.NConcurrent

retryMultipliedPeriod

public IntFunction<net.thevpc.nuts.time.NDuration> retryMultipliedPeriod(net.thevpc.nuts.time.NDuration base,
                                                                         double multiplier)

Specified by:

retryMultipliedPeriod in interface net.thevpc.nuts.concurrent.NConcurrent

defaultBulkheadCallFactory

public net.thevpc.nuts.concurrent.NBulkheadCallFactory defaultBulkheadCallFactory()

Specified by:

defaultBulkheadCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

memoryBulkheadCallFactory

public net.thevpc.nuts.concurrent.NBulkheadCallFactory memoryBulkheadCallFactory()

Specified by:

memoryBulkheadCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

bulkheadCallFactory

public net.thevpc.nuts.concurrent.NBulkheadCallFactory bulkheadCallFactory()

Specified by:

bulkheadCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent

bulkheadCallFactory

public net.thevpc.nuts.concurrent.NConcurrent bulkheadCallFactory(net.thevpc.nuts.concurrent.NBulkheadCallFactory bulkheadCallFactory)

Specified by:

bulkheadCallFactory in interface net.thevpc.nuts.concurrent.NConcurrent