Ограничение размера очереди асинхронных запросов

Я использую Cassandra Java Driver 2.0 в асинхронном режиме. Когда я выполняю много операций очень интенсивно, они должны быть помещены в очередь где-то внутри драйвера, прежде чем они будут отправлены в сеть.

Я хотел бы установить предел размера очереди. Я не нашел никаких параметров драйвера Java для этого. Также я ожидаю что-то похожее на механизм RejectedExecutionHandler в ThreadPoolExecotor. Можно ли как-то сделать с Cassandra Java Driver?

Источник

1 ответ

Решение

AFAIK, вы не можете установить ограничение размера очереди. Что вам нужно, это, возможно, PoolingOptions. Организация очереди зависит от способности узлов принимать больше запросов. Если вы пытаетесь настроить возможность перед постановкой в ​​очередь, вероятно, PoolingOptions - это ответ, если вы хотите настроить максимальный размер очереди, чтобы отклонять дальнейшие запросы, на самом деле, вы не можете. Однако вы всегда можете запросить улучшение здесь

Источник
Другие вопросы по тегам