内存队列

动手造轮子 - 实现支持 Ack 的内存队列

这里我们创建了一个并且指定了AckTimeout为 1s 来方便测试,并向队列里添加了两条消息,然后再从队列中取出消息进行消费,输出结果如下:AckQueue前面两个分别取出了队列里的两条消息,第三次没有取到消息返回了 ,因为此时队列中没有消息,之后将没有 a

队列 ack 内存队列 2025-01-12 08:31  4