摘要：迭代器智能嗎第一步，將列表中的根節(jié)點(diǎn)找出來(lái)。源碼翻開(kāi)中迭代器的源碼。在迭代器對(duì)象執(zhí)行操作之前，都會(huì)執(zhí)行方法，以判斷當(dāng)前操作下是否安全。

ConcurrentModificationException這個(gè)異常大家都很熟悉，當(dāng)在forEach進(jìn)行刪除時(shí)都會(huì)出現(xiàn)該異常。

如果你還不了解，請(qǐng)參考澍澍的博客：關(guān)于在list循環(huán)的過(guò)程中進(jìn)行刪除的處理 - 晨澍的博客

ConcurrentModificationException的解決方案之一是使用迭代器，但是不代表迭代器就一勞永逸了。

使用的時(shí)候還需斟酌數(shù)組的索引。

如下圖所示：

原來(lái)的同步方法獲取的節(jié)點(diǎn)是節(jié)點(diǎn)的父節(jié)點(diǎn)，根據(jù)父節(jié)點(diǎn)進(jìn)行對(duì)應(yīng)。

然而在同步更新文件的時(shí)候，發(fā)現(xiàn)這樣并不好處理，在不改動(dòng)原代碼的情況下，設(shè)計(jì)了將列表轉(zhuǎn)為樹(shù)型結(jié)構(gòu)的方法，這樣可以從根節(jié)點(diǎn)向下開(kāi)始遍歷，便于操作。

也是在?？途W(wǎng)身經(jīng)百戰(zhàn)，實(shí)現(xiàn)這個(gè)難度不大。但在編寫(xiě)相關(guān)實(shí)現(xiàn)的時(shí)候，遇到了一個(gè)小問(wèn)題。

第一步，將列表中的根節(jié)點(diǎn)找出來(lái)。

@Override
public ClusterNode listToTree(List clusterNodes) {
    logger.debug("聲明根節(jié)點(diǎn)名稱(chēng)");
    final String ROOT_NAME = "ROOT";

    logger.debug("聲明根節(jié)點(diǎn)");
    ClusterNode rootNode = null;

    logger.debug("獲取迭代器，遍歷節(jié)點(diǎn)列表");
    Iterator iterator = clusterNodes.iterator();
    while (iterator.hasNext()) {

        logger.debug("向后遍歷");
        ClusterNode clusterNode = iterator.next();

        if (ROOT_NAME.equals(clusterNode.getName())) {
            logger.debug("獲取到根節(jié)點(diǎn)，賦值，并從原列表中移除");
            rootNode = clusterNode;
            iterator.remove();
            break;
        }
    }

    logger.debug("設(shè)置子節(jié)點(diǎn)");
    assert rootNode != null;
    setChildrenNode(rootNode, clusterNodes);

    return rootNode;
}

第二步，再?gòu)母?jié)點(diǎn)開(kāi)始，遞歸設(shè)置子節(jié)點(diǎn)。

/**
 * 為節(jié)點(diǎn)設(shè)置符合條件的子節(jié)點(diǎn)，同時(shí)遞歸，設(shè)置子節(jié)點(diǎn)的子節(jié)點(diǎn)
 * @param parentNode   父節(jié)點(diǎn)
 * @param clusterNodes 子節(jié)點(diǎn)列表
 */
private void setChildrenNode(ClusterNode parentNode, List clusterNodes) {
    logger.debug("清空原集合");
    parentNode.getClusterNodes().clear();

    logger.debug("遍歷列表");
    Iterator iterator = clusterNodes.iterator();
    while (iterator.hasNext()) {
        ClusterNode clusterNode = iterator.next();

        logger.debug("如果父節(jié)點(diǎn)匹配");
        if (clusterNode.getParentClusterNode().getName().equals(parentNode.getName())) {
            logger.debug("將當(dāng)前節(jié)點(diǎn)添加到父節(jié)點(diǎn)的子列表中");
            parentNode.getClusterNodes().add(clusterNode);

            logger.debug("移除該節(jié)點(diǎn)");
            iterator.remove();

            logger.debug("遞歸設(shè)置子節(jié)點(diǎn)");
            setChildrenNode(clusterNode, clusterNodes);
        }
    }
}

思想肯定是沒(méi)問(wèn)題的。

調(diào)用了一行遞歸，當(dāng)我在編寫(xiě)這行代碼的時(shí)候就已經(jīng)察覺(jué)到可能不對(duì)了，因?yàn)楸敬蔚鬟€沒(méi)有迭代完，條件符合時(shí)就去遞歸，然后遞歸又去新建迭代器，遞歸中又可能刪除新元素，再遞歸回來(lái)，繼續(xù)迭代的結(jié)果還正確嗎？

logger.debug("遞歸設(shè)置子節(jié)點(diǎn)");
setChildrenNode(clusterNode, clusterNodes);

本著完全相信JDK的思想，興許我憂(yōu)慮的事情，其實(shí)大牛們?cè)缇蛶臀医鉀Q了呢？雖然感覺(jué)可能不對(duì)，但還是這樣寫(xiě)了。想著把測(cè)試用例寫(xiě)得完善一些，錯(cuò)了再改唄！

一測(cè)試，果然出錯(cuò)了！在調(diào)用next方法時(shí)拋出了ConcurrentModificationException異常，看來(lái)，迭代器還沒(méi)有智能到如此地步。

翻開(kāi)ArrayList中迭代器的源碼。(自從上次在慕課網(wǎng)的驅(qū)動(dòng)下，強(qiáng)制自己閱讀了HashMap的源碼后，發(fā)現(xiàn)自己對(duì)讀源碼沒(méi)那么抗拒了。)

在刷過(guò)編程題后，終于明白為什么這些家公司都問(wèn)HashMap源碼，HashMap真的是太重要了，可以在實(shí)際業(yè)務(wù)中大大降低算法的時(shí)間復(fù)雜度！

/**
 * Returns an iterator over the elements in this list in proper sequence.
 *
 * 
The returned iterator is fail-fast.
 *
 * @return an iterator over the elements in this list in proper sequence
 */
public Iterator iterator() {
    return new Itr();
}

迭代器方法內(nèi)部就返回了一個(gè)Itr的對(duì)象，這是ArrayList中的私有內(nèi)部類(lèi)，為什么要用內(nèi)部類(lèi)呢？一大好處就是內(nèi)部類(lèi)可以直接訪問(wèn)外部類(lèi)的私有成員，具體進(jìn)行集合操作的時(shí)候非常方便。

ConcurrentModificationException，因?yàn)槭殖Ｒ?jiàn)，所以我們常常只關(guān)注了這個(gè)異常怎么出現(xiàn)的，往往忽略了異常本身。

并發(fā)修改異常，最簡(jiǎn)單的場(chǎng)景，就是線程不安全的多線程并發(fā)場(chǎng)景。

在迭代器對(duì)象執(zhí)行操作之前，都會(huì)執(zhí)行checkForComodification方法，以判斷當(dāng)前操作下是否安全。就像下面的代碼實(shí)現(xiàn)一樣，判斷當(dāng)前的數(shù)量是否是我預(yù)期的數(shù)量。

如果不是，表示有人動(dòng)過(guò)我的列表，拋異常，不干了。

如果是，表示沒(méi)有人動(dòng)過(guò)我的列表，才繼續(xù)執(zhí)行。

final void checkForComodification() {
    if (modCount != expectedModCount)
        throw new ConcurrentModificationException();
}

既然出現(xiàn)了問(wèn)題，怎么解決呢？

那就不要在遍歷的過(guò)程中再去遞歸修改了，等他遍歷完再說(shuō)。添加一個(gè)待處理的列表，遍歷之后再遞歸，保證每次迭代都不沖突。

logger.debug("下一次需要處理的父節(jié)點(diǎn)");
List nextParentNodes = new ArrayList<>();

logger.debug("遍歷列表");
Iterator iterator = clusterNodes.iterator();
while (iterator.hasNext()) {
    ClusterNode clusterNode = iterator.next();

    logger.debug("如果父節(jié)點(diǎn)匹配");
    if (clusterNode.getParentClusterNode().getName().equals(parentNode.getName())) {
        logger.debug("將當(dāng)前節(jié)點(diǎn)添加到父節(jié)點(diǎn)的子列表中");
        parentNode.getClusterNodes().add(clusterNode);

        logger.debug("移除該節(jié)點(diǎn)");
        iterator.remove();

        logger.debug("添加到下一次父節(jié)點(diǎn)中");
        nextParentNodes.add(clusterNode);
    }
}

logger.debug("遞歸處理所有待處理的父節(jié)點(diǎn)");
for (ClusterNode clusterNode : nextParentNodes) {
    setChildrenNode(clusterNode, clusterNodes);
}

迭代器并非一勞永逸，保證多次修改的獨(dú)立才是最佳實(shí)踐。