net.thevpc.nuts.runtime.standalone.concurrent

Class NConcurrentImpl

java.lang.Object

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

All Implemented Interfaces:

NConcurrent, NComponent

public class NConcurrentImpl
extends Object
implements NConcurrent

Constructor Summary

Constructors

Constructor and Description
NConcurrentImpl()

Method Summary

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

setCachedValueFactory

public NConcurrent setCachedValueFactory(NCachedValueFactory cachedValueFactory)

Specified by:

setCachedValueFactory in interface NConcurrent

memoryCachedValueFactory

public NCachedValueFactory memoryCachedValueFactory()

Specified by:

memoryCachedValueFactory in interface NConcurrent

defaultCachedValueFactory

public NCachedValueFactory defaultCachedValueFactory()

Specified by:

defaultCachedValueFactory in interface NConcurrent

cachedValueFactory

public NCachedValueFactory cachedValueFactory()

Specified by:

cachedValueFactory in interface NConcurrent

setRetryCallFactory

public NConcurrent setRetryCallFactory(NRetryCallFactory retryCallFactory)

Specified by:

setRetryCallFactory in interface NConcurrent

memoryRetryCallFactory

public NRetryCallFactory memoryRetryCallFactory()

Specified by:

memoryRetryCallFactory in interface NConcurrent

defaultRetryCallFactory

public NRetryCallFactory defaultRetryCallFactory()

Specified by:

defaultRetryCallFactory in interface NConcurrent

retryCallFactory

public NRetryCallFactory retryCallFactory()

Specified by:

retryCallFactory in interface NConcurrent

setOnceValueFactory

public NConcurrent setOnceValueFactory(NOnceValueFactory onceValueFactory)

Specified by:

setOnceValueFactory in interface NConcurrent

memoryOnceValueFactory

public NOnceValueFactory memoryOnceValueFactory()

Specified by:

memoryOnceValueFactory in interface NConcurrent

defaultOnceValueFactory

public NOnceValueFactory defaultOnceValueFactory()

Specified by:

defaultOnceValueFactory in interface NConcurrent

onceValueFactory

public NOnceValueFactory onceValueFactory()

Specified by:

onceValueFactory in interface NConcurrent

defaultRateLimitValueFactory

public NRateLimitValueFactory defaultRateLimitValueFactory()

Specified by:

defaultRateLimitValueFactory in interface NConcurrent

defaultSagaFactory

public NSagaCallableFactory defaultSagaFactory()

Specified by:

defaultSagaFactory in interface NConcurrent

memorySagaFactory

public NSagaCallableFactory memorySagaFactory()

Specified by:

memorySagaFactory in interface NConcurrent

memoryRateLimitValueFactory

public NRateLimitValueFactory memoryRateLimitValueFactory()

Specified by:

memoryRateLimitValueFactory in interface NConcurrent

setRateLimitValueFactory

public NConcurrent setRateLimitValueFactory(NRateLimitValueFactory factory)

Specified by:

setRateLimitValueFactory in interface NConcurrent

rateLimitValueFactory

public NRateLimitValueFactory rateLimitValueFactory()

Specified by:

rateLimitValueFactory in interface NConcurrent

sagaFactory

public NSagaCallableFactory sagaFactory()

Specified by:

sagaFactory in interface NConcurrent

cachedValue

public <T> NCachedValue<T> cachedValue(Supplier<T> supplier)

Specified by:

cachedValue in interface NConcurrent

onceValue

public <T> NOnceValue<T> onceValue(Supplier<T> supplier)

Specified by:

onceValue in interface NConcurrent

cachedValue

public <T> NCachedValue<T> cachedValue(String id,
                                       Supplier<T> supplier)

Specified by:

cachedValue in interface NConcurrent

onceValue

public <T> NOnceValue<T> onceValue(String id,
                                   Supplier<T> supplier)

Specified by:

onceValue in interface NConcurrent

retryCall

public <T> NRetryCall<T> retryCall(String id,
                                   NCallable<T> callable)

Specified by:

retryCall in interface NConcurrent

retryCall

public <T> NRetryCall<T> retryCall(NCallable<T> callable)

Specified by:

retryCall in interface NConcurrent

circuitBreakerCall

public <T> NCircuitBreakerCall<T> circuitBreakerCall(NCallable<T> callable)

Specified by:

circuitBreakerCall in interface NConcurrent

circuitBreakerCall

public <T> NCircuitBreakerCall<T> circuitBreakerCall(String id,
                                                     NCallable<T> callable)

Specified by:

circuitBreakerCall in interface NConcurrent

setCircuitBreakerCallFactory

public NConcurrent setCircuitBreakerCallFactory(NCircuitBreakerCallFactory circuitBreakerCallFactory)

Specified by:

setCircuitBreakerCallFactory in interface NConcurrent

memoryCircuitBreakerCallFactory

public NCircuitBreakerCallFactory memoryCircuitBreakerCallFactory()

Specified by:

memoryCircuitBreakerCallFactory in interface NConcurrent

defaultCircuitBreakerCallFactory

public NCircuitBreakerCallFactory defaultCircuitBreakerCallFactory()

Specified by:

defaultCircuitBreakerCallFactory in interface NConcurrent

circuitBreakerCallFactory

public NCircuitBreakerCallFactory circuitBreakerCallFactory()

Specified by:

circuitBreakerCallFactory in interface NConcurrent

executorService

public ExecutorService executorService()

Specified by:

executorService in interface NConcurrent

sagaCallBuilder

public NSagaCallableBuilder sagaCallBuilder()

Specified by:

sagaCallBuilder in interface NConcurrent

defaultWorkBalancerFactory

public NWorkBalancerFactory defaultWorkBalancerFactory()

Specified by:

defaultWorkBalancerFactory in interface NConcurrent

memoryWorkBalancerFactory

public NWorkBalancerFactory memoryWorkBalancerFactory()

Specified by:

memoryWorkBalancerFactory in interface NConcurrent

workBalancerFactory

public NWorkBalancerFactory workBalancerFactory()

Specified by:

workBalancerFactory in interface NConcurrent

setWorkBalancerCallFactory

public NConcurrent setWorkBalancerCallFactory(NWorkBalancerFactory workBalancerCallFactory)

Specified by:

setWorkBalancerCallFactory in interface NConcurrent

sleep

public NConcurrent sleep(NDuration durationMillis)
                  throws NInterruptedException

Specified by:

sleep in interface NConcurrent

Throws:

NInterruptedException

sleep

public NConcurrent sleep(Duration durationMillis)
                  throws NInterruptedException

Specified by:

sleep in interface NConcurrent

Throws:

NInterruptedException

sleep

public NConcurrent sleep(long durationMillis)
                  throws NInterruptedException

Specified by:

sleep in interface NConcurrent

Throws:

NInterruptedException

taskSet

public NTaskSet taskSet()

Specified by:

taskSet in interface NConcurrent

retryFixedPeriod

public IntFunction<NDuration> retryFixedPeriod(NDuration period)

Specified by:

retryFixedPeriod in interface NConcurrent

retryFixedPeriods

public IntFunction<NDuration> retryFixedPeriods(NDuration... periods)

Specified by:

retryFixedPeriods in interface NConcurrent

retryMultipliedPeriod

public IntFunction<NDuration> retryMultipliedPeriod(NDuration base,
                                                    double multiplier)

Specified by:

retryMultipliedPeriod in interface NConcurrent

defaultBulkheadCallFactory

public NBulkheadCallFactory defaultBulkheadCallFactory()

Specified by:

defaultBulkheadCallFactory in interface NConcurrent

memoryBulkheadCallFactory

public NBulkheadCallFactory memoryBulkheadCallFactory()

Specified by:

memoryBulkheadCallFactory in interface NConcurrent

bulkheadCallFactory

public NBulkheadCallFactory bulkheadCallFactory()

Specified by:

bulkheadCallFactory in interface NConcurrent

setBulkheadCallFactory

public NConcurrent setBulkheadCallFactory(NBulkheadCallFactory bulkheadCallFactory)

Specified by:

setBulkheadCallFactory in interface NConcurrent