문제

비동기 모드에서 Cassandra Java 드라이버 2.0을 사용하고 있습니다.많은 작업을 매우 집중적으로 실행 중이면 네트워크로 전송하기 전에 운전자 어딘가에 대기해야합니다.

큐 크기 제한을 설정하고 싶습니다.저는 해당 Java 드라이버 매개 변수를 찾지 못했습니다.또한 ThreadPoolExecotor의 거부 된 무자비와 비슷한 것을 기대합니다.Cassandra Java 드라이버로 어떻게 든 할 수 있습니까?

도움이 되었습니까?

해결책

afaik 대기열 크기 한도를 설정할 수 없습니다.필요한 것은 아마도 "Nofollow"> PoolingOptions ...에큐잉은 더 많은 요청을 수락하는 노드 기능에 따라 다릅니다.시도하는 것이 큐잉 아마도 PoolingOptions가 큐를 조정하기 전에 큐를 조정하는 것입니다. 원하는 대기열의 최대 크기를 조정하여 AFAIK를 거부 할 수있는 큐의 최대 크기를 조정하는 것입니다.그러나 여기

라이센스 : CC-BY-SA ~와 함께 속성
제휴하지 않습니다 StackOverflow
scroll top