net.thevpc.nuts.runtime.standalone.concurrent

Class DefaultNConcurrentRPI

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.DefaultNConcurrentRPI

All Implemented Interfaces:

NConcurrentRPI, NComponent

public class DefaultNConcurrentRPI
extends Object
implements NConcurrentRPI

Constructor Summary

Constructors

Constructor and Description
DefaultNConcurrentRPI()

Method Summary

Modifier and Type	Method and Description
<T> NCachedValue<T>	cachedValue(String id, Supplier<T> supplier)
<T> NCachedValue<T>	cachedValue(Supplier<T> supplier)
<T> NCircuitBreakerCall<T>	createCircuitBreakerCall(NCallable<T> callable)
<T> NCircuitBreakerCall<T>	createCircuitBreakerCall(String id, NCallable<T> callable)
<T> NOnceValue<T>	createOnceValue(String id, Supplier<T> supplier)
<T> NOnceValue<T>	createOnceValue(Supplier<T> supplier)
<T> NRetryCall<T>	createRetryCall(NCallable<T> callable)
<T> NRetryCall<T>	createRetryCall(String id, NCallable<T> callable)
NRetryPeriodFunction	createRetryExponentialPeriod(NDuration base, double multiplier)
NRetryPeriodFunction	createRetryFixedPeriods(NDuration... periods)
NRetryPeriodFunction	createRetryMultipliedPeriod(NDuration base, double multiplier)
NTaskSet	createTaskSet()
NBulkheadCallFactory	getBulkheadCallFactory()
NCachedValueFactory	getCachedValueFactory()
NCircuitBreakerCallFactory	getCircuitBreakerCallFactory()
NLockFactory	getCurrentLockFactory()
NBulkheadCallFactory	getDefaultBulkheadCallFactory()
NCachedValueFactory	getDefaultCachedValueFactory()
NCircuitBreakerCallFactory	getDefaultCircuitBreakerCallFactory()
NLockFactory	getDefaultLockFactory()
NOnceValueFactory	getDefaultOnceValueFactory()
NRateLimitValueFactory	getDefaultRateLimitValueFactory()
NRetryCallFactory	getDefaultRetryCallFactory()
NSagaCallableFactory	getDefaultSagaFactory()
NWorkBalancerFactory	getDefaultWorkBalancerFactory()
ExecutorService	getExecutorService()
NBulkheadCallFactory	getMemoryBulkheadCallFactory()
NCachedValueFactory	getMemoryCachedValueFactory()
NCircuitBreakerCallFactory	getMemoryCircuitBreakerCallFactory()
NLockFactory	getMemoryLockFactory()
NOnceValueFactory	getMemoryOnceValueFactory()
NRateLimitValueFactory	getMemoryRateLimitValueFactory()
NRetryCallFactory	getMemoryRetryCallFactory()
NWorkBalancerFactory	getMemoryWorkBalancerFactory()
NOnceValueFactory	getOnceValueFactory()
NRateLimitValueFactory	getRateLimitValueFactory()
NRetryCallFactory	getRetryCallFactory()
NSagaCallableFactory	getSagaFactory()
NWorkBalancerFactory	getWorkBalancerFactory()
NSagaCallableFactory	memorySagaFactory()
NSagaCallableBuilder	sagaCallBuilder()
NSagaCallableBuilder	sagaCallBuilder(String id)
void	setBulkheadCallFactory(NBulkheadCallFactory bulkheadCallFactory)
void	setCachedValueFactory(NCachedValueFactory cachedValueFactory)
void	setCircuitBreakerCallFactory(NCircuitBreakerCallFactory circuitBreakerCallFactory)
void	setCurrentLockFactory(NLockFactory lockFactory)
void	setOnceValueFactory(NOnceValueFactory onceValueFactory)
void	setRateLimitValueFactory(NRateLimitValueFactory factory)
void	setRetryCallFactory(NRetryCallFactory retryCallFactory)
void	setSagaFactory(NSagaCallableFactory factory)
void	setWorkBalancerCallFactory(NWorkBalancerFactory workBalancerCallFactory)
void	sleep(Duration durationMillis)
void	sleep(long durationMillis)
void	sleep(NDuration durationMillis)

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.internal.rpi.NConcurrentRPI

of

Constructor Detail

DefaultNConcurrentRPI

public DefaultNConcurrentRPI()

Method Detail

createTaskSet

public NTaskSet createTaskSet()

Specified by:

createTaskSet in interface NConcurrentRPI

setCurrentLockFactory

public void setCurrentLockFactory(NLockFactory lockFactory)

Specified by:

setCurrentLockFactory in interface NConcurrentRPI

getMemoryLockFactory

public NLockFactory getMemoryLockFactory()

Specified by:

getMemoryLockFactory in interface NConcurrentRPI

getDefaultLockFactory

public NLockFactory getDefaultLockFactory()

Specified by:

getDefaultLockFactory in interface NConcurrentRPI

getCurrentLockFactory

public NLockFactory getCurrentLockFactory()

Specified by:

getCurrentLockFactory in interface NConcurrentRPI

setCachedValueFactory

public void setCachedValueFactory(NCachedValueFactory cachedValueFactory)

Specified by:

setCachedValueFactory in interface NConcurrentRPI

getMemoryCachedValueFactory

public NCachedValueFactory getMemoryCachedValueFactory()

Specified by:

getMemoryCachedValueFactory in interface NConcurrentRPI

getDefaultCachedValueFactory

public NCachedValueFactory getDefaultCachedValueFactory()

Specified by:

getDefaultCachedValueFactory in interface NConcurrentRPI

getCachedValueFactory

public NCachedValueFactory getCachedValueFactory()

Specified by:

getCachedValueFactory in interface NConcurrentRPI

setRetryCallFactory

public void setRetryCallFactory(NRetryCallFactory retryCallFactory)

Specified by:

setRetryCallFactory in interface NConcurrentRPI

getMemoryRetryCallFactory

public NRetryCallFactory getMemoryRetryCallFactory()

Specified by:

getMemoryRetryCallFactory in interface NConcurrentRPI

getDefaultRetryCallFactory

public NRetryCallFactory getDefaultRetryCallFactory()

Specified by:

getDefaultRetryCallFactory in interface NConcurrentRPI

getRetryCallFactory

public NRetryCallFactory getRetryCallFactory()

Specified by:

getRetryCallFactory in interface NConcurrentRPI

setOnceValueFactory

public void setOnceValueFactory(NOnceValueFactory onceValueFactory)

Specified by:

setOnceValueFactory in interface NConcurrentRPI

getMemoryOnceValueFactory

public NOnceValueFactory getMemoryOnceValueFactory()

Specified by:

getMemoryOnceValueFactory in interface NConcurrentRPI

getDefaultOnceValueFactory

public NOnceValueFactory getDefaultOnceValueFactory()

Specified by:

getDefaultOnceValueFactory in interface NConcurrentRPI

getOnceValueFactory

public NOnceValueFactory getOnceValueFactory()

Specified by:

getOnceValueFactory in interface NConcurrentRPI

getDefaultRateLimitValueFactory

public NRateLimitValueFactory getDefaultRateLimitValueFactory()

Specified by:

getDefaultRateLimitValueFactory in interface NConcurrentRPI

getDefaultSagaFactory

public NSagaCallableFactory getDefaultSagaFactory()

Specified by:

getDefaultSagaFactory in interface NConcurrentRPI

memorySagaFactory

public NSagaCallableFactory memorySagaFactory()

Specified by:

memorySagaFactory in interface NConcurrentRPI

getMemoryRateLimitValueFactory

public NRateLimitValueFactory getMemoryRateLimitValueFactory()

Specified by:

getMemoryRateLimitValueFactory in interface NConcurrentRPI

setRateLimitValueFactory

public void setRateLimitValueFactory(NRateLimitValueFactory factory)

Specified by:

setRateLimitValueFactory in interface NConcurrentRPI

getRateLimitValueFactory

public NRateLimitValueFactory getRateLimitValueFactory()

Specified by:

getRateLimitValueFactory in interface NConcurrentRPI

getSagaFactory

public NSagaCallableFactory getSagaFactory()

Specified by:

getSagaFactory in interface NConcurrentRPI

setSagaFactory

public void setSagaFactory(NSagaCallableFactory factory)

Specified by:

setSagaFactory in interface NConcurrentRPI

cachedValue

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

Specified by:

cachedValue in interface NConcurrentRPI

createOnceValue

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

Specified by:

createOnceValue in interface NConcurrentRPI

cachedValue

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

Specified by:

cachedValue in interface NConcurrentRPI

createOnceValue

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

Specified by:

createOnceValue in interface NConcurrentRPI

createRetryCall

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

Specified by:

createRetryCall in interface NConcurrentRPI

createRetryCall

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

Specified by:

createRetryCall in interface NConcurrentRPI

createCircuitBreakerCall

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

Specified by:

createCircuitBreakerCall in interface NConcurrentRPI

createCircuitBreakerCall

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

Specified by:

createCircuitBreakerCall in interface NConcurrentRPI

setCircuitBreakerCallFactory

public void setCircuitBreakerCallFactory(NCircuitBreakerCallFactory circuitBreakerCallFactory)

Specified by:

setCircuitBreakerCallFactory in interface NConcurrentRPI

getMemoryCircuitBreakerCallFactory

public NCircuitBreakerCallFactory getMemoryCircuitBreakerCallFactory()

Specified by:

getMemoryCircuitBreakerCallFactory in interface NConcurrentRPI

getDefaultCircuitBreakerCallFactory

public NCircuitBreakerCallFactory getDefaultCircuitBreakerCallFactory()

Specified by:

getDefaultCircuitBreakerCallFactory in interface NConcurrentRPI

getCircuitBreakerCallFactory

public NCircuitBreakerCallFactory getCircuitBreakerCallFactory()

Specified by:

getCircuitBreakerCallFactory in interface NConcurrentRPI

getDefaultBulkheadCallFactory

public NBulkheadCallFactory getDefaultBulkheadCallFactory()

Specified by:

getDefaultBulkheadCallFactory in interface NConcurrentRPI

getMemoryBulkheadCallFactory

public NBulkheadCallFactory getMemoryBulkheadCallFactory()

Specified by:

getMemoryBulkheadCallFactory in interface NConcurrentRPI

getBulkheadCallFactory

public NBulkheadCallFactory getBulkheadCallFactory()

Specified by:

getBulkheadCallFactory in interface NConcurrentRPI

setBulkheadCallFactory

public void setBulkheadCallFactory(NBulkheadCallFactory bulkheadCallFactory)

Specified by:

setBulkheadCallFactory in interface NConcurrentRPI

sagaCallBuilder

public NSagaCallableBuilder sagaCallBuilder()

Specified by:

sagaCallBuilder in interface NConcurrentRPI

sagaCallBuilder

public NSagaCallableBuilder sagaCallBuilder(String id)

Specified by:

sagaCallBuilder in interface NConcurrentRPI

getDefaultWorkBalancerFactory

public NWorkBalancerFactory getDefaultWorkBalancerFactory()

Specified by:

getDefaultWorkBalancerFactory in interface NConcurrentRPI

getMemoryWorkBalancerFactory

public NWorkBalancerFactory getMemoryWorkBalancerFactory()

Specified by:

getMemoryWorkBalancerFactory in interface NConcurrentRPI

getWorkBalancerFactory

public NWorkBalancerFactory getWorkBalancerFactory()

Specified by:

getWorkBalancerFactory in interface NConcurrentRPI

setWorkBalancerCallFactory

public void setWorkBalancerCallFactory(NWorkBalancerFactory workBalancerCallFactory)

Specified by:

setWorkBalancerCallFactory in interface NConcurrentRPI

createRetryExponentialPeriod

public NRetryPeriodFunction createRetryExponentialPeriod(NDuration base,
                                                         double multiplier)

Specified by:

createRetryExponentialPeriod in interface NConcurrentRPI

createRetryFixedPeriods

public NRetryPeriodFunction createRetryFixedPeriods(NDuration... periods)

Specified by:

createRetryFixedPeriods in interface NConcurrentRPI

createRetryMultipliedPeriod

public NRetryPeriodFunction createRetryMultipliedPeriod(NDuration base,
                                                        double multiplier)

Specified by:

createRetryMultipliedPeriod in interface NConcurrentRPI

getExecutorService

public ExecutorService getExecutorService()

Specified by:

getExecutorService in interface NConcurrentRPI

sleep

public void sleep(NDuration durationMillis)
           throws NInterruptedException

Specified by:

sleep in interface NConcurrentRPI

Throws:

NInterruptedException

sleep

public void sleep(Duration durationMillis)
           throws NInterruptedException

Specified by:

sleep in interface NConcurrentRPI

Throws:

NInterruptedException

sleep

public void sleep(long durationMillis)
           throws NInterruptedException

Specified by:

sleep in interface NConcurrentRPI

Throws:

NInterruptedException