需要类似于Java的LinkedBlockingQueue的东西。
感兴趣的方法:
还需要保证FIFO。
经过一些搜索(但尚未测试):我找到了ConcurrentQueue(具有FIFO行为),BlockingCollection(FIFO或非FIFO?)。
感兴趣的方法:
messageQueue.poll(120000, TimeUnit.MILLISECONDS);
的含义是,尝试获取项目,并且如果在X个时间单位内仍然没有项目,则返回null。还需要保证FIFO。
经过一些搜索(但尚未测试):我找到了ConcurrentQueue(具有FIFO行为),BlockingCollection(FIFO或非FIFO?)。