java – 迭代时更新PriorityQueue

我需要根据ID更新PriorityQueue中的一些固定优先级元素.我认为这是一种非常常见的情况,这是一个示例代码段(Android 2.2)：

for (Entry e : mEntries) {
    if (e.getId().equals(someId)) {
        e.setData(newData);
    }
}

然后我使Entry“不可变”(没有setter方法),以便创建一个新的Entry实例并由setData()返回.我将我的方法修改为：

for (Entry e : mEntries) {
    if (e.getId().equals(someId)) {
        Entry newEntry = e.setData(newData);
        mEntries.remove(e);
        mEntries.add(newEntry);
     }
}

代码似乎运行正常,但有人指出在迭代时修改队列是一个坏主意：它可能抛出一个ConcurrentModificationException,我需要将我想要删除的元素添加到ArrayList并稍后删除它.他没有解释原因,对我来说这看起来很费劲,但我在互联网上找不到任何具体的解释.

(This post是类似的,但优先级可以改变,这不是我的情况)

任何人都可以澄清我的代码有什么问题,我应该如何改变它 – 最重要的是 – 为什么？

谢谢,
Rippel

PS：一些实施细节……

PriorityQueue<Entry> mEntries = new PriorityQueue<Entry>(1, Entry.EntryComparator());

有：

public static class EntryComparator implements Comparator<Entry> {
    public int compare(Entry my, Entry their) {
        if (my.mPriority < their.mPriority) {
            return 1;
        }
        else if (my.mPriority > their.mPriority) {
            return -1;
        }
        return 0;
    }
}

解决方法:

此代码位于PriorityQueue的Java 6实现中：

private class Itr implements Iterator<E> {
  /**
   * The modCount value that the iterator believes that the backing
   * Queue should have.  If this expectation is violated, the iterator
   * has detected concurrent modification.
   */
  private int expectedModCount = modCount;

  public E next() {
    if(expectedModCount != modCount) {
      throw new ConcurrentModificationException();
    }


  }

}

现在,为什么这个代码在这里？如果查看Javadoc for ConcurrentModificationException,您会发现如果在迭代完成之前对底层集合进行修改,则迭代器的行为是未定义的.因此,许多集合实现了这种modCount机制.

修复你的代码

您需要确保不要在循环中修改代码.如果您的代码是单线程的(如图所示),那么您可以按照同事的建议进行操作,然后将其复制到列表中以供日后使用.此外,记录了Iterator.remove()方法的使用以防止ConcurrentModificationExceptions.一个例子：

List<Entry> toAdd = new ArrayList<Entry>();
Iterator it = mEntries.iterator();
while(it.hasNext()) {
  Entry e = it.next();

  if(e.getId().equals(someId)) {
    Entry newEntry = e.setData(newData);
    it.remove();
    toAdd.add(newEntry);
  }
}
mEntries.addAll(toAdd);

java – 迭代时更新PriorityQueue

相关推荐