2个线程同时访问一个同步函数答案

【问题标题】：2 threads accessing at the same time to a synchronized function2个线程同时访问一个同步函数
【发布时间】：2017-01-23 09:56:42
【问题描述】：

我有一个程序可以根据 cpu 的内核数自动生成线程（在我的情况下为 2，因为我在 VM 中运行该程序）

我有一个名为 createTable 的函数，如果它不存在，它会创建一个表，问题是我有多个线程，所以 IF 语句可能没用，我尝试使用同步但结果相同

public synchronized void createTable(Utils utils, String tableName, RowSerializable row) {
   if(!utils.getClient().tableExists(tableName)) {
       this.table = utils.generateTable(tableName, row);
       this.fieldsNames = utils.getNamesOfColumns(table);
   }
}

有什么想法吗？

【问题讨论】：

你能提供更多细节吗？如果线程之间共享底层对象的相同实例，则同步方法就足够了。是你的情况吗？
您创建了多少包含此代码的对象？同步将在 object 级别进行。如果每个线程创建一个单独的对象，则不会有同步。
你是从两个不同的对象调用方法吗？如果是，在这种情况下，它将锁定两个不同的对象，因此将允许两个线程访问此方法代码。否则采取类级锁定。（使方法静态）
该方法仅从一个对象@AndrewHenle 调用，但从不是我的代码调用，我使用的是 Apache Flink API
@A.Vadillo 你怎么知道它是对象的同一个实例？一个快速测试是改为在静态对象上进行同步。

标签： java multithreading parallel-processing

【解决方案1】：

您可能会使用多个实例，否则在一个实例上同步的方法访问上不会出现同步问题。

为了解决您的问题，您可以在所有实例共享的静态字段上进行同步。

在类中添加一个静态Object并开启同步，应该可以解决访问并发的问题：

   public class YourClassThatHasTheProblem {
   ...
   private static final Object lock = new Object();
   ... 
    public void createTable(Utils utils, String tableName, RowSerializable row) {
      synchronized (lock) {
        if(!utils.getClient().tableExists(tableName)) {
          this.table = utils.generateTable(tableName, row);
          this.fieldsNames = utils.getNamesOfColumns(table);
         }
       }
  }
 ...
}

如果它不能解决您的问题，则意味着问题不仅仅来自代码同步，而是因为您在另一个类或方法中执行了类似的处理，并且与此调用不同步。因此，它会通过 createTable() 调用产生副作用。

【讨论】：

我也猜，我更想看看他是如何在线程之间共享同一个实例的。但当然，静态字段既简单又有效。
我认为它有效！我会继续测试这个程序。谢谢
@AxelH 确实，我理解，但我不确定 OP 是否真的知道创建竞争条件的资源是如何实例化的。如果解决方案有效，它还可以帮助 OP 意识到他使用多个实例，然后研究其代码以理解。
@A.Vadillo 如果对您有帮助，那就太好了 :)
@davidxxx 完全同意你的看法。在最坏的情况下，这将帮助不需要了解这些实例的初始化过程的读者。

【解决方案2】：

有可能有2个线程正在访问createTable方法，我会试着解释一下。

这个方法定义了synchronized，也就是说它同步的对象是this。所以我的猜测是，在你的程序中，2 个线程可能会访问 createTable，因为有两个不同的对象，每个 createTable 同步。

因此，如果 2 个线程想要创建具有相同名称的新表 - 这是可能的。

注意：此分析基于您提供的信息，如果您认为不太可能，请提供更多信息，我会尽力提供帮助。

【讨论】：

这个thread 可以显示您解释的内容以及更多内容（静态）
这是同一个实例，所以两个线程都试图创建表。第一个创建它，第二个抛出异常