5

下面是一些伪代码。

public class MyObject
{   
    private List<Object> someStuff;
    private Timer timer;

    public MyObject()
    {
        someStuff = new ArrayList<Object>();

        timer = new Timer(new TimerTask(){

            public void run()
            {
                for(Object o : someStuff)
                {
                    //do some more stuff involving add and removes possibly
                }
            }
        }, 0, 60*1000);
    }

    public List<Object> getSomeStuff()
    {
        return this.someStuff;
    }
}

所以本质上问题是上面代码中没有列出的其他对象调用 getSomeStuff() 来获取列表以用于只读目的。发生这种情况时，我在计时器线程中收到并发修改异常。我尝试使 getSomeStuff 方法同步，甚至尝试在计时器线程中同步块，但仍然不断收到错误。停止并发访问列表的最简单方法是什么？

4

2 回答 2

14

在迭代线程中的列表之前，您可以使用java.util.concurrent.CopyOnWriteArrayList或制作副本（或使用方法获取数组）。Collection.toArray

除此之外，在 for-each 构造中删除会破坏迭代器，因此在这种情况下它不是处理列表的有效方法。

但您可以执行以下操作：

for (Iterator<SomeClass> i = list.iterator(); i.hasNext();) {
    SomeClass next = i.next();
    if (need_to_remove){
       i.remove(i);                
    }
}

或者

for (int i = list.size() - 1; i >= 0; i--){            
    if (need_to_remove) {
        list.remove(i);                
    }
}

另请注意，如果您的代码从不同的线程访问列表并且列表被修改，则需要同步它。例如：

    private final ReadWriteLock lock = new ReentrantReadWriteLock();


    final Lock w = lock.writeLock();
    w.lock();
    try {
        // modifications of the list
    } finally {
        w.unlock();
    }

      .................................

    final Lock r = lock.readLock();
    r.lock();
    try {
        // read-only operations on the list
        // e.g. copy it to an array
    } finally {
        r.unlock();
    }
    // and iterate outside the lock

但请注意，带锁的操作应尽可能短。

于 2012-04-18T22:20:50.880 回答
4

您应该在 中制作列表的副本getSomeStuff()。像这样发布对私有字段的引用会使其有效地公开，因此无论如何您都不想这样做。

此外，请考虑将副本作为ImmutableList或至少作为不可修改的列表返回。

于 2012-04-18T22:23:26.360 回答