Package com.alibaba.cloud.seata.feign.hystrix

Class SeataHystrixConcurrencyStrategy

java.lang.Object

com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

com.alibaba.cloud.seata.feign.hystrix.SeataHystrixConcurrencyStrategy

public class SeataHystrixConcurrencyStrategy
extends com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

Author:

xiaojing

Constructor Summary

Constructors

Constructor	Description
SeataHystrixConcurrencyStrategy()

Method Summary

Modifier and Type	Method	Description
BlockingQueue<Runnable>	getBlockingQueue(int maxQueueSize)
<T> com.netflix.hystrix.strategy.concurrency.HystrixRequestVariable<T>	getRequestVariable(com.netflix.hystrix.strategy.concurrency.HystrixRequestVariableLifecycle<T> rv)
ThreadPoolExecutor	getThreadPool(com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey, com.netflix.hystrix.HystrixThreadPoolProperties threadPoolProperties)
ThreadPoolExecutor	getThreadPool(com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey, com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> corePoolSize, com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> maximumPoolSize, com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
<K> Callable<K>	wrapCallable(Callable<K> c)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SeataHystrixConcurrencyStrategy

public SeataHystrixConcurrencyStrategy()

Method Details

getThreadPool

public ThreadPoolExecutor getThreadPool(com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey,
 com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> corePoolSize,
 com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> maximumPoolSize,
 com.netflix.hystrix.strategy.properties.HystrixProperty<Integer> keepAliveTime,
 TimeUnit unit,
 BlockingQueue<Runnable> workQueue)

Overrides:

getThreadPool in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

getThreadPool

public ThreadPoolExecutor getThreadPool(com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey,
 com.netflix.hystrix.HystrixThreadPoolProperties threadPoolProperties)

Overrides:

getThreadPool in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

getBlockingQueue

public BlockingQueue<Runnable> getBlockingQueue(int maxQueueSize)

Overrides:

getBlockingQueue in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

getRequestVariable

public <T>
com.netflix.hystrix.strategy.concurrency.HystrixRequestVariable<T> getRequestVariable(com.netflix.hystrix.strategy.concurrency.HystrixRequestVariableLifecycle<T> rv)

Overrides:

getRequestVariable in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy

wrapCallable

public <K> Callable<K> wrapCallable(Callable<K> c)

Overrides:

wrapCallable in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy