Java中的 ConcurrentLinkedQueue iterator() 方法

简介

在Java中，ConcurrentLinkedQueue是一个线程安全、无边界、基于链表实现的队列。它提供了一个 iterator() 方法，可以返回一个迭代器，用于遍历队列中的元素。

方法签名

public Iterator<E> iterator()

返回值类型

Iterator<E>

线程安全性

ConcurrentLinkedQueue是一个线程安全的队列，因此它的iterator()方法也是线程安全的。它可以在多线程环境下，安全地被多个线程同时使用。

方法说明

iterator()方法返回一个迭代器，用于遍历ConcurrentLinkedQueue队列中的元素。由于ConcurrentLinkedQueue是一个基于链表实现的队列，因此元素之间是没有顺序关系的。迭代器会从头开始遍历队列，直到队列末尾。在遍历过程中，如果有其他线程对队列进行修改，则迭代器也会相应地更新迭代器状态，以反映修改后的队列状态。

代码示例

import java.util.Iterator;
import java.util.concurrent.ConcurrentLinkedQueue;

public class ConcurrentLinkedQueueExample {
    public static void main(String[] args) {
        ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<>();
        queue.add(1);
        queue.add(2);
        queue.add(3);

        // 获取迭代器
        Iterator<Integer> iterator = queue.iterator();

        // 遍历队列中的元素
        while (iterator.hasNext()) {
            int num = iterator.next();
            System.out.println(num);
        }
    }
}

输出结果：

1
2
3

注意事项

1. 迭代器遍历时，在多线程环境下可能会存在失败的可能。也就是说，在迭代的过程中，如果有其他线程修改了队列中的元素，那么会抛出 ConcurrentModificationException 异常。

2. 在使用迭代器进行遍历时，应该优先考虑使用 for-each 循环，而不是直接使用 while 循环加 next() 方法。因为在多线程情况下，使用 for-each 循环可以避免 ConcurrentModificationException 异常的发生。