我需要以循环并发的方式从队列中获取数据。我正在寻找一个实现这种行为的集合。经过一些搜索,我找不到一个合适的集合。我该如何实现呢?
我看了
我猜我可以使用
=============================更新===========================
在初始化阶段,多个线程将向此类集合添加元素。并发集合的状态将对将逐个从中消耗一个项目的使用者线程正确可见。一旦应用程序处于运行状态,将不会向集合添加元素。每个线程按循环方式迭代和消耗一个元素。
ConcurrentLinkedQueue
,但我不确定如何使它成为循环的。我需要这个集合的性能非常高。我猜我可以使用
ConcurrentLinkedDeque
来完成。通过使用迭代器,我应该能够迭代到最后,一旦到达末尾,我就可以重新创建我的迭代器并从开头开始。=============================更新===========================
在初始化阶段,多个线程将向此类集合添加元素。并发集合的状态将对将逐个从中消耗一个项目的使用者线程正确可见。一旦应用程序处于运行状态,将不会向集合添加元素。每个线程按循环方式迭代和消耗一个元素。