update 优化 销毁策略

master
疯狂的狮子Li 1 year ago
parent 476c7a77c8
commit 99d9c516fc

@ -174,11 +174,11 @@ public class QueueUtils {
* *
* @param queueName * @param queueName
* @param capacity * @param capacity
* @param destroy * @param destroy
*/ */
public static <T> boolean trySetBoundedQueueCapacity(String queueName, int capacity, boolean destroy) { public static <T> boolean trySetBoundedQueueCapacity(String queueName, int capacity, boolean destroy) {
RBoundedBlockingQueue<T> boundedBlockingQueue = CLIENT.getBoundedBlockingQueue(queueName); RBoundedBlockingQueue<T> boundedBlockingQueue = CLIENT.getBoundedBlockingQueue(queueName);
if (boundedBlockingQueue.isExists() && destroy) { if (destroy) {
destroyQueue(queueName); destroyQueue(queueName);
} }
return boundedBlockingQueue.trySetCapacity(capacity); return boundedBlockingQueue.trySetCapacity(capacity);

Loading…
Cancel
Save