update 优化 有界队列销毁方式 应该使用特殊销毁方法

This commit is contained in:
疯狂的狮子Li 2024-11-29 16:26:56 +08:00
parent 99d9c516fc
commit 87294b41af

View File

@ -179,7 +179,7 @@ public class QueueUtils {
public static <T> boolean trySetBoundedQueueCapacity(String queueName, int capacity, boolean destroy) {
RBoundedBlockingQueue<T> boundedBlockingQueue = CLIENT.getBoundedBlockingQueue(queueName);
if (destroy) {
destroyQueue(queueName);
boundedBlockingQueue.delete();
}
return boundedBlockingQueue.trySetCapacity(capacity);
}