我在异步模式下使用cassandra java驱动程序2.0。当我非常集中执行大量操作时,他们必须在驾驶员内的某处排队,然后在他们发送到网络之前。

我想设置队列大小限制。我没有找到任何Java驱动程序参数。此外,我期望类似于ThreadPoolExecotor中的拒绝redenedexecutionHandler机制。有可能用Cassandra Java驱动程序做一些吗?

有帮助吗?

解决方案

afaik您无法设置队列大小 limit。您需要的是可能是 poolingoptions 。队列取决于接受更多请求的节点功能。如果你尝试的是调整排队前的能力可能是池塘代选择是答案,如果你想要的是调整队列的最大大小来拒绝进一步的请求,你不能。但是,您可以始终提取改进 - 请求这里

许可以下: CC-BY-SA归因
不隶属于 StackOverflow
scroll top