Hystrix线程池属性

Question

在我们的应用程序中，我们使用Hystrix，因为我们调用了几个外部服务。我们希望为我们调用的每个外部服务配置一个具有特定大小的线程池。

假设有三个外部服务，称为S1、S2、S3。此外，我们有10个扩展hystrixcommand的类，称为C1到C10。

C1和C2调用S1，应该使用相同的线程池，有15个线程。在C1的构造函数内部，我们对super进行以下调用：

super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("S1"))
    .andThreadPoolKey(ThreadPools.S1)
    .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter().withCoreSize(15))
    .andCommandPropertiesDefaults(HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(timeout)));

在一个命令(C1)的构造函数中，我们将S1的线程池大小指定为15。ThreadPools是一个自定义类，其中finalstatic属性s1由

S1 = HystrixThreadPoolKey.Factory.asKey("S1");

现在实际的问题是，(1)为什么线程池核心大小（对于S1是15）是在hystrixcommand中指定的，而不是中心线程池定义（这似乎不是Hystrix的概念）。

假设在c2的构造函数中（与上面的代码段看起来相同），我们要用一个不是15的参数调用withCoreSize。（2）采用哪一种？

（3）有没有办法在一个类中定义服务S1、S2和S3的三个线程池，并从命令类中引用它们？

Hystrix如何使用指南似乎不包含与此相关的信息。如果有人有时间回答这个问题，那就太好了。

Answer 1

您可以定义一个名为config.properties的属性文件，该文件如下所示：

    hystrix.threadpool.S1.coreSize=15
    hystrix.threadpool.S1.maximumSize=15
    hystrix.threadpool.S1.maxQueueSize=15
    hystrix.threadpool.S1.queueSizeRejectionThreshold=300
    hystrix.threadpool.S1.allowMaximumSizeToDivergeFromCoreSize=true
    hystrix.threadpool.S1.keepAliveTimeMinutes=1

    hystrix.threadpool.S2.coreSize=20
    hystrix.threadpool.S2.maximumSize=20
    hystrix.threadpool.S2.maxQueueSize=20
    hystrix.threadpool.S2.queueSizeRejectionThreshold=300
    hystrix.threadpool.S2.allowMaximumSizeToDivergeFromCoreSize=true
    hystrix.threadpool.S2.keepAliveTimeMinutes=1

...

下面是关于coreSize、maximumSize和MaxQueueSize之间区别的一个很好的解释：

https://github.com/netflix/hystrix/issues/1554