public class ConcurrencyStrategyWithExplicitCoreSize
extends com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy
HystrixThreadPool.HystrixThreadPoolDefault
calls HystrixConcurrencyStrategy.getThreadPool(com.netflix.hystrix.HystrixThreadPoolKey,
com.netflix.hystrix.strategy.properties.HystrixProperty, com.netflix.hystrix.strategy.properties.HystrixProperty,
com.netflix.hystrix.strategy.properties.HystrixProperty, java.util.concurrent.TimeUnit,
java.util.concurrent.BlockingQueue)
with HystrixThreadPoolProperties.coreSize()
for BOTH
size arguments, meaning that thread pools by default have a fixed size.Modifier and Type | Method and Description |
---|---|
static ConcurrencyStrategyWithExplicitCoreSize |
getInstance() |
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) |
public static ConcurrencyStrategyWithExplicitCoreSize getInstance()
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)
getThreadPool
in class com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy
Copyright © 2015. All rights reserved.