MySql死锁/提交未在c#中解锁？

Question

谁能告诉我为什么下面的代码会死锁？我正在控制台应用程序中的多个线程上模拟我们的网络服务器。

控制台应用有 5 个线程，每个线程更新 250 条记录。

我发现 transaction.Commit() 是不够的，我会遇到死锁，所以它显然没有释放锁。

除非我将 transaction.Dispose() 和 Sleep(50ms) 放入，否则我总是在 innodb 上遇到死锁。如果我把代码变成一个存储过程，那么睡眠需要更大以避免死锁。我不确定它实际上是否完全避免了它们，需要使用更多线程来运行它。

在事务处理后关闭连接更可靠，但在理想情况下，在 Web 应用中，我们希望每个请求都有一个连接以提高性能。

另外，在避免死锁方面，使用 transaction.Dispose() 比使用 (var transaction = ...

我们目前使用的是 .NET，而不是 .NET 核心。

我敢打赌，如果我使用 SqlClient for Sql/Server 编写相同的程序，它会起作用 - 我明天会尝试。

谁能解释一下？我做错了什么？

static void Main(string[] args)
{
    Console.WriteLine("GenerateBarcodesTestConsoleApp");

    var connectionString = ConfigurationManager.ConnectionStrings["MyConnection"].ConnectionString;

    var threads = Enumerable.Range(1, 5);

    Parallel.ForEach(threads, t =>
    {
        GenerateBarcodes2(t, connectionString, 250);
    });

    Console.WriteLine("Press any key to exit...");
    Console.ReadKey();
}

static void GenerateBarcodes2(int thread, string connectionString, int numberToGenerate)
{
    using (var con = new MySqlConnection(connectionString))
    {
        con.Open();

        var sql1 = "SELECT p.barcode, p..barcode_id " +
                    "FROM p_barcode p " +
                    "WHERE p.company_id = 1 " +
                    "AND SUBSTRING(p.barcode,1,2) = 'OK' " +
                    "AND players.in_use = 0 " +
                    "LIMIT 1 " +
                    "FOR UPDATE;";

        var sql2 = "UPDATE p_barcode SET in_use = 1 WHERE company_id = 1 AND barcode_id = ?barcode_id AND in_use = 0";

        for (int b = 0; b < numberToGenerate; b++)
        {
            using (var transaction = con.BeginTransaction(System.Data.IsolationLevel.RepeatableRead))
            {
                string barcode = string.Empty;
                int barcodeId = 0;

                using (var cmd = new MySqlCommand(sql1, con, transaction))
                {
                    var rdr = cmd.ExecuteReader();
                    if (rdr.Read())
                    {
                        barcode = (string)rdr["barcode"];
                        barcodeId = (int)rdr["barcode_id"];
                    }
                    rdr.Close();

                    Console.WriteLine(barcode);
                }

                if (barcodeId != 0)
                {
                    using (var cmd = new MySqlCommand(sql2, con, transaction))
                    {
                        cmd.Parameters.AddWithValue("barcode_id", barcodeId);

                        cmd.ExecuteNonQuery();
                    }
                }

                transaction.Commit();
                System.Threading.Thread.Sleep(50);
            }
            //transaction.Dispose();
        }

        con.Close();
    }
}

Answer 1

在 MariaDb 中，SKIP LOCKED 是防止死锁的解决方案。

没有防止死锁的完美解决方案，无需重新设计系统以避免两个线程同时尝试更新同一记录，但是在提交事务后添加一个小睡眠似乎有很大帮助。在我的开发机器上大约需要 20 毫秒。

这是否表明在数据库实际提交事务并释放锁之前提交返回？无论哪种方式，这种行为对于 INNODB 和 MARIADB 都是相同的。