确保轮询 BoundedBlockingQueue redisson

问题描述

RBoundedBlockingQueue<Integer> queue = redissonClient.getBoundedBlockingQueue("queue");
queue.trySetCapacity(5);
boolean offer = queue.offer(index,9,TimeUnit.SECONDS);
{
   fun1();
   //do something make server crash like outOfMemory
}
Integer poll = queue.poll(1,TimeUnit.MINUTES);

一个像上面一样的 RBoundedBlockingQueue,如果服务器在 fun1() 中宕机,queue.poll() 将失败,队列将满并且永远无法添加新元素,我该怎么做才能使元素轮询成功?或者我可以做些什么来为队列中的元素设置超时,然后它会在时间到时销毁

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)