问题描述
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 (将#修改为@)