一、前言
并发队列里面的Iterators是弱一致性的,next返回的是队列某一个时间点或者创建迭代器时候的状态的反映。当创建迭代器后,其他线程删除了该元素时候并不会抛出java.util.ConcurrentModificationException异常,能够保持创建迭代器后的元素一定被正确的next出来。
二、 ConcurrentLinkedQueue类图结构
以ConcurrentLinkedQueue为例说下是如何实现的,如图内部的Itr类实现了接口Iterator的功能。
三、测试代码
3.1 实验一
本实验是测试获取迭代器后调用next前删除元素看看会有什么结果
主线程debug断点查看图:
如图主线程获取了队列元素zlx节点的迭代器,在调用next的时候debug阻塞主。
下面激活SleepInterrupt线程,执行remove操作:
remove后调度到主线程执行
可知还是迭代出来了已经删除的元素,并且没抛出异常。
3.2 试验2
本实验测试获取迭代器前调用next后删除迭代器后面的元素看看有什么结果
主线程debug断点图
下面激活SleepInterrupt线程,执行remove操作:
remove后调度到主线程执行
可知现在队列里面没有了gh元素,下面看看迭代结果
3.3 试验3
本实验测试获取迭代器前调用next后删除迭代器后面的元素看看有什么结果
下面看看迭代结果
四、源码分析
首先调用队列的iterator()方法时候会实例化一个迭代器,所以每次调用该方法都是一个新的实例,构造函数内部调用了advance方法,目的是确定第一个元素的iterator.
Itr() {advance();//(1)}//获取队列中下一个可用节点。调用next()时候返回节点值,或者返回nullprivate E advance() { //lastRet记录调用最后一次调用next时候的节点lastRet = nextNode;(2) //x存放节点值E x = nextItem;(3) //获取next节点Node<E> pred, p; //如果为nul则调用阻塞队列的first方法获取if (nextNode == null) {p = first();//(4)pred = null;} else { //不为nul则获取下一个节点(5)pred = nextNode;p = succ(nextNode);} for (;;) { //p=null则直接返回,重置节点null(6)if (p == null) {nextNode = null;nextItem = null; return x;} //否者记录当前节点并返回值E item = p.item; if (item != null) {//(7)nextNode = p;nextItem = item; return x;} else { // 跳过null值节点(8)Node<E> next = succ(p); if (pred != null && next != null)pred.casNext(p, next);p = next;}}
}
//判断是否有原始public boolean hasNext() { return nextNode != null;
}//有则删除public E next() { if (nextNode == null) throw new NoSuchElementException(); return advance();
}//删除元素public void remove() {Node<E> l = lastRet; if (l == null) throw new IllegalStateException(); // rely on a future traversal to relink.l.item = null;lastRet = null;
}
下面看图说话:
那么调用队列的iterator时候执行(1)(4)(7)后队列状态图:
调用hasNext()时候知道nextNode != null所以返回true.
然后调用next()方法执行(2)(5)(7)后,返回zlx,队列状态图
也就说第一次调用队列的iterator方法会在构造函数调用advance方法一次,这时候已经把队列第一个可用的节点指针赋值给nextNode,节点值赋值给nextItem;这样当调用hasNext时候先看nextNode是否null,null说明队列为空则返回false说明队列里面没有元素,否者会调用next方法,该方法会再次调用advance方法,由于调用hasNext确定了nextNode不为null所以会调用(5)来获取下次调用next要返回的值,也就是当前nextNode的后继节点。如果后继节点为null则返回nextNode对应的值nextItem,否者设置下一次调用next时候需要的nextNode和nextItem。
下面考虑下实验一的情况,首先线程1调用调用hasNext()后情况为:
现在在调用next方法(2)(5)(7)后的状态为:
试验2的结果很明显,这里不再说了,下面看看试验3
然后调用remove方法因为lastRet=null所以抛出了异常,其实应该先调用next方法在调用remove方法。
然后看remove里面并没有看到有对队列里面的头尾节点进行操作,也就说并没有在队列中移除该元素的操作,乍一看这有问题,但是没问题:下面看删除zlx后队列状态
也就是remove仅仅把节点内容变为null,所以head还是指向这个元素(注意本节讲的都是不带哨兵节点的队列,正常情况下队列一开始有个null的哨兵节点,如果本节考虑的话,那么上面的图应该有两个null节点,一个是哨兵,一个是zlx节点变成的)
而poll时候如果节点内容为null则会继续查看后继节点,所以这里remove简单的把节点内容变为null即可。
四、总结
并发队列里面的迭代器通过使用nextItem保留创建迭代器时候的节点的值,保证了在调用hasNext和next方法之间其他线程删除该元素后还可以正常返回删除节点的内容,并不抛出异常,之所以说是弱一致性是因为调用next时候该元素已经不在队列里面了,但是迭代返回还可以返回。另外remove操作并没有立刻把删除的原始从队列中干掉,而是在出队时候从队列里面解除,让它变为自引用节点,等待被垃圾回收。
如果感觉写的好,就打赏下小编吧^-^