为什么我需要同步 Collections.synchronizedList 返回的列表

multithreading java synchronization arraylist

2022-09-01 19:11:59

我在 dos.oracle.com 找到了这个

公共静态列表同步列表（列表列表）

返回由指定列表支持的同步（线程安全）列表。为了保证串行访问，对后备列表的所有访问都必须通过返回的列表完成，这一点至关重要。用户在迭代返回的列表时必须手动同步该列表：

  List list = Collections.synchronizedList(new ArrayList());
      ...
  synchronized(list) {
      Iterator i = list.iterator(); // Must be in synchronized block
      while (i.hasNext())
          foo(i.next());
  }

我的问题是：如果应该返回已经同步的列表，为什么我必须同步列表来迭代它？Collections.synchronizedList();

我只是在两个线程中访问列表：一个线程只是添加，另一个线程要获取和删除。建议在此方案中使用哪些其他类？

感谢您的阅读。

答案 1

正在同步的列表仅意味着等操作是同步的，因此是原子的。然而，迭代不是，如果一个线程在另一个线程正在迭代时，你可以得到一个 ConcurrentModificationException。addremoveadds

通过手动同步迭代块，可以确保在迭代时不修改列表。

一种替代方法是使用 CopyOnWriteArrayList，它提供了一个迭代器，该迭代器可以迭代迭代开始时已知的列表，而不考虑后续修改。但是，如果您需要经常更改列表的内容，则该集合不是很有效。

答案 2

起初，我对这个话题有点困惑，因为我找到的大多数例子都没有上下文。我终于找到了这篇为我解决问题的博客文章：http://netjs.blogspot.de/2015/09/how-and-why-to-synchronize-arraylist-in-java.html

从上面的例子来看，我只需要使用 Collections.synchronizeList（）转换我的列表，然后我就可以添加和删除项目，而不必担心线程安全。但在这里，重要的是要注意，在将列表传递给不同的线程之前，您必须对其进行同步，否则列表访问不是互斥的。

因此，一个完整的示例是：

public class SynchroProblem implements Runnable{
  private List<Integer> myList;

  //Constructor
  public SynchroProblem(List<Integer> myList){
    this.myList = myList;
  }

  @Override
  public void run() {
    // Do stuff with the list .add(), .remove(), ...
    myList.add(5);

    // Even if mylist is synchronized the iterator is not, 
    // so for using the iterator we need the synchronized block
    synchronized (myList){
      // do stuff with iterator e.g.
      Iterator<Integer> iterator = myList.iterator();
      while (iterator.hasNext()){
        int number = iterator.next();
        if (number == 123){
          iterator.remove();
        }
      }

    }
  }

  public static void main(String[] args) {

    List<Integer> originalList = new ArrayList<Integer>();

    // Synchronize list
    List<Integer> syncList = Collections.synchronizedList(originalList);

    // Create threads and pass the synchronized list
    Thread t1 = new Thread(new SynchroProblem(syncList));
    Thread t2 = new Thread(new SynchroProblem(syncList));

    t1.start();
    t2.start();

  }
}