我必须在哪里使用同步？

Question

我做了一些研究，但找不到解决这个问题的方法。

从这个主题Synchronization, When to or not to use? 我知道我可以使用synchronized，但这样做并不能解决问题。

情况是我有一个方法，其中Thread 用于创建ArrayList。在同一个Thread 中，另一个method 在BufferedReader 完成读取文件并且行被添加到第一个列表后被调用。

在第二种方法中，第一个列表用于创建第二个列表。完成所有操作后，第一个方法使用第二个列表。

这是我使用的代码，如果有不清楚的地方请询问，我会尽力提供所需的信息。

public synchronized void theBaseList() {
    Thread t = new Thread() {
        @override
        public void run() {
          try(
              while((line = br.readLine()) != null) {
                  firstList.add(line):
              }
          }
          nextMethod();
          currentObject = (Object[]) secondList.get(0); // throws an exception
          }
      }
  };
  t.start();

---

public synchronized void nextMethod() {
    Thread t1 = new Thread(){
        double objectListSize = calculateObjectListLength(firstList.size());
        @override
        public void run() {
          try {
              // create Objects
              secondList.add(objects);
            }
         }
      };
      t1.start();
}

当我在nextMethod() 中使用Thread 从第一个列表中的项目中创建一个新的对象list 时，我得到一个ArrayIndexOutOfBoundsException 说

线程“Thread-4”java.lang.IndexOutOfBoundsException 中的异常：索引：0，大小：0

我通过在第二种方法中不使用Thread 来避免这种情况，并且一切正常。

如果我确实使用了 2 个Threads 并同时使用了两个方法synchronized，它仍然会抛出异常。

是否有可能或者我应该通过在第二种方法中不使用Thread 来解决？我以为synchronized 是用来处理这类问题的。我不明白为什么它不起作用。

Answer 1

假设您的方法定义在一个名为 Sample 的类中，并且您创建了一个实例 mySample。这似乎是您的代码正在执行的操作：

main thread calls mySample.theBaseList() and synchronizes by locking on mySample.
  theBaseList() defines thread1 and starts it.
  theBaseList() exits scope, thus unlocking on mySample.

thread1 reads in the lines of a file and adds them to list1 (these operations are not synchronized)
thread1 calls mySample.nextMethod()
mySample.nextMethod() synchronizes by locking on mySample
    nextMethod() defines thread2 and starts it.
    nextMethod() exits scope, thus unlocking on mySample.

* thread2 sets up list2 (these operations are not synchronized)
* thread1, having returned from nextMethod() reads from list2 (these operations are not synchronized)

最后两个操作是你的竞争条件的原因。

在您的情况下，使用同步方法可能过于粗粒度。更好的选择可能是在两个线程都操作的对象上进行同步，即 secondList。

nextMethod();
synchronized(secondList) {
    currentObject = (Object[]) secondList.get(0); // should no longer throw an exception
}

synchronized(secondList) {
    // create Objects
    secondList.add(objects);
}

编辑：

synchronized(secondList) {
    nextMethod();
    secondList.wait();
    currentObject = (Object[]) secondList.get(0); // should no longer throw an exception
}

synchronized(secondList) {
    // create Objects
    secondList.add(objects);
    secondList.notifyAll();
}