Java和同步两个线程

Question

我有两个线程修改相同的对象。这些对象是ArrayList（不是向量）中的自定义、非同步对象。我想让这两个线程很好地协同工作，因为它们是同时被调用的。

这是线程 1 中唯一重要的方法。

public void doThread1Action() {
  //something...
  for(myObject x : MyArrayList){
    modify(x);
  }
}

这是线程2中的一个方法：

public void doThread2Action() {   
  //something...
  for(myObject x : MyArrayList){
    modifyAgain(x);
  }
}

目前，在测试时，我偶尔会遇到`ConcurrentModificationExceptions`。 （我认为这取决于线程 1 在线程 2 尝试修改对象之前完成迭代的速度。）

我是否认为通过简单地将synchronized 附加到这两个方法的开头，线程将以同步的方式一起工作，而不是尝试访问ArrayList？还是应该将ArrayList 更改为Vector？

Answer 1

ConcurrentModificationException 并非源于修改集合中的对象，而是源于在迭代器处于活动状态时从集合中添加/删除。

共享资源是集合，必须有第三种方法使用和添加/删除。要获得正确的并发性，您必须在访问它的所有方法中同步对集合资源的访问。

为避免同步块过长，一种常见的模式可能是将集合复制到同步块中，然后对其进行迭代。如果您这样做，请注意您首先谈论的问题（对象的并发修改）再次出现 - 但这次您可以锁定另一个资源。

Answer 2

您不需要同步对列表的访问，只要您不对其进行结构性修改，即只要您不从列表中添加或删除对象。你也不应该看到ConcurrentModificationExceptions，因为只有在你对列表进行结构性修改时才会抛出这些。

因此，假设您只修改列表中包含的对象，但不添加或删除或重新排序列表中的对象，则可以在修改时对包含的对象进行同步，如下所示：

void modifyAgain(MyObject x) {
    synchronized(x) {
        // do the modification
    }
}

我不会在 modifyAgain() 方法上使用 synchronized 修饰符，因为这不允许同时修改列表中的两个不同对象。

另一个线程中的modify()方法当然必须和modifyAgain()一样实现。

Answer 3

您需要在同一个锁上同步访问集合，因此仅在方法上使用同步关键字（假设它们在不同的类中）将锁定两个不同的对象。

所以这里是你可能需要做的一个例子：

Object lock = new Object();

public void doThread1Action(){

//something...
    synchronized(lock){
        for(myObject x : MyArrayList){
           modify(x);
    }

}

public void doThread2Action(){

//something...
    synchronized(lock){
        for(myObject x : MyArrayList){
            modifyAgain(x);
    }

}

您也可以考虑使用CopyOnWriteArrayList 而不是Vector

Answer 4

我猜你的问题与ConcurrentModificationException 有关。这个类在它的 Java 文档中说：

/**
* 检测到的方法可能会抛出此异常 并发
* 修改对象时不进行此类修改 允许的。

*/

在您的情况下，问题是列表中的迭代器并且可能会被修改。我想通过以下实现你的问题将是唯一的：

public void doThread1Action()
{
    synchronized(x //for sample)
    {
       //something...
       for(myObject x : MyArrayList)
       {
          modify(x);
       }
    }
}

然后：

public void doThread2Action()
{
    synchronized(x //for sample)
    {
       //something...
       for(myObject x : MyArrayList)
       {
          modifyAgain(x);
       }
    }
}

为了获得更好的结果，我希望有人纠正我的解决方案。