java - 在另一个线程中迭代时添加到队列

Question

在我的游戏中，我从客户端接收输入作为事件，并将其存储在队列中。

private Queue<Event> unprocessedEvents = new LinkedList<>();

@Override
public void onEvent(@NotNull Event event) {
    unprocessedEvents.add(event);
}

队列在服务器的单独线程上每秒处理 10 次。

Iterator<Event> eventIterator = unprocessedEvents.iterator();
while (eventIterator.hasNext()) {
    Event event = eventIterator.next();

    //Handle the input from the client/server
    Event event = input(event);

    //Remove the event from the unprocessed inputs
    eventIterator.remove(); //ConcurrentModificationException
}

有时，当我在迭代队列时尝试插入事件时，会收到 ConcurrentModificationException。现在我不确定处理队列的最佳解决方案是什么？

我应该在这里使用同步 block 吗？ Collections.synchronizedList()、CopyOnWriteArrayList、BlockingQueue？

我可以维护一个单独的队列并使用 addAll() 将新队列添加到 unprocessedEvents 吗？

Answer 1

您可能想使用ConcurrentLinkedQueue因为它 native 处理并发线程访问。