c# - MySQL C# 异步方法不起作用？

Question

我在服务器中有一个数据库，似乎异步方法不起作用。

这是我的代码:

static async void Example()
{
    string connectionString =
        "Server=mydomainname.com;" +
        "Port=3306;" +
        "Database=scratch;" +
        "Uid=Assassinbeast;" +
        "Password=mypass123;" +
        "AllowUserVariables= true;";

    MySql.Data.MySqlClient.MySqlConnection sqConnection = new MySql.Data.MySqlClient.MySqlConnection(connectionString);
    await sqConnection.OpenAsync();

    Console.Write("Opened. Now Click to close");
    Console.ReadLine();

    sqConnection.Close();
}
static void Main(string[] args)
{
    Console.ReadLine();
    Example();
    Console.WriteLine("Done");
    Console.ReadLine();
}

在“await”语句中，它实际上应该跳回到 Main() 函数并写出“Done”。但它没有那样做。它只是同步运行，就像它不是异步方法一样，一旦函数完全完成，它将首先写入“完成”。

那我做错了什么？是错误吗？

更新

好吧，在我得到一些答案之后，我实际上仍然看不出 OpenAsync() 和 Open() 之间有任何区别。

我开始尝试测试更多东西，我想我可以得出结论，异步方法不起作用

这是我的新代码:

static async Task Example()
{
    string connectionString =
        "Server=mydomainname.com;" +
        "Port=3306;" +
        "Database=scratch;" +
        "Uid=Assassinbeast;" +
        "Password=mypass123;" +
        "AllowUserVariables= true;";

    using (var sqConnection = new MySql.Data.MySqlClient.MySqlConnection(connectionString))
    {
        Console.WriteLine("Opening");
        await sqConnection.OpenAsync();
        Console.WriteLine("Opened. Now Closing");
    }
}
static async Task Example2()
{
    //Lets pretend this is a database that my computer will try to connect to

    Console.WriteLine("Opening");
    await Task.Delay(1000); //Lets say it takes 1 second to open
    Console.WriteLine("Opened. Now Closing");
}
static void Main(string[] args)
{
    Console.ReadLine();

    Task.Run(() => Example());
    Task.Run(() => Example());
    Task.Run(() => Example());
    Task.Run(() => Example());
    Task.Run(() => Example());
    Task.Run(() => Console.WriteLine("Done"));
    Console.ReadLine();
}

这里，当我运行 Example() 5 次时，它将输出如下:

它最多需要 3 秒才能写出“完成”。请注意，我的计算机根本没有使用 CPU，因为它只是在等待并连接到数据库，连接大约需要 1 秒。

所以它实际上阻塞了我的计算机线程并且没有运行多线程，否则它会立即写出“完成”。

所以如果我调用 Example2() 而不是 Example()，那么我得到的结果就是我想要的和我期望的:

在这里，它是真正的异步方法，因为我在只有 2 个内核的计算机上一次可以做 6 件以上的事情。但是第一个例子，我一次只能做两件事，因为 MySQL 异步方法不起作用。

我还使用 sqConnection.Open() 对其进行了测试，它与 sqConnection.OpenAsync() 的结果完全相同

所以现在，我只是不知道如何同时连接到数据库 5 次。

Answer 1

从一些旧代码 (6.7.2) 来看，mysql ADO.NET 提供程序似乎没有正确实现任何异步功能。这包括 TAP 模式和旧式的 Begin..., End... 异步模式。在该版本中，似乎根本没有编写 Db* 异步方法；他们将使用 .NET 中的基类，它们是同步的，看起来都像这样:

public virtual Task<int> ExecuteNonQueryAsync(...) {
    return Task.FromResult(ExecuteNonQuery(...));
}

(100% 与将其包装在任务中的额外开销同步；reference source here)

如果 Begin 和 End 版本编写正确(它们不是)，它可以像这样实现:

public override Task<int> ExecuteNonQueryAsync(...) {
    return Task<int>.Factory.FromAsync(BeginExecuteNonQueryAsync, EndExecuteNonQueryAsync, null);
}

( reference source for that method for SqlCommand )

这样做依赖于底层套接字的某种回调 api，最终以调用者通过套接字发送一些字节的模式进行处理，然后在准备好时从底层网络堆栈回调已注册的方法.

但是，mysql 连接器不会这样做(它首先不会覆盖该方法；但如果覆盖了，相关的开始和结束方法在某些底层套接字 api 上不是异步的)。 mysql 连接器的作用 instead正在为当前连接实例上的内部方法构建委托(delegate)，并在单独的线程上同步调用它。例如，您不能同时在同一连接上执行第二条命令，如下所示:

private static void Main() {
    var sw = new Stopwatch();
    sw.Start();
    Task.WaitAll(
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync(),
        GetDelayCommand().ExecuteNonQueryAsync());
    sw.Stop();
    Console.WriteLine(sw.Elapsed.Seconds);
}

private static DbCommand GetDelayCommand() {
    var connection = new MySqlConnection (...);
    connection.Open();
    var cmd = connection.CreateCommand();
    cmd.CommandText = "SLEEP(5)";
    cmd.CommandType = CommandType.Text;
    return cmd;
}

(假设您使用的是连接池，并且那里的任务数量超过了最大池大小；如果异步工作，则此代码将根据池中的连接数量获得一个数字，而不是一个取决于连接池和可以同时运行的线程数)

这是因为代码有一个lock on the driver (管理网络内部的实际事物；*)。如果它没有(并且内部是线程安全的，并且使用其他一些方式来管理连接池)it goes on to perform blocking calls on the underlying network stream .

是的，目前看不到此代码库的异步支持。如果有人可以向我指出代码，我可以查看更新的驱动程序，但我怀疑基于内部 NetworkStream 的对象看起来没有明显不同，异步代码看起来也没有太大不同。支持async 的驱动程序会将大部分内部组件编写为依赖于异步方式，并为同步代码提供同步包装器；或者，它看起来更像 SqlClient 引用源，并依赖于一些 Task 包装库来抽象出同步运行或异步运行之间的差异。

* 锁定驱动程序并不意味着它不可能使用非阻塞 IO，只是该方法不能用锁定语句编写并使用非阻塞 Begin/End IAsyncResult 可以在 TAP 模式之前编写的代码。

编辑:下载6.9.8；怀疑没有运行的异步代码(非阻塞 IO 操作)；这里有一个错误:https://bugs.mysql.com/bug.php?id=70111

2016 年 7 月 6 日更新:GitHub 上有趣的项目可能最终在 https://github.com/mysql-net/MySqlConnector 解决这个问题(可能会使用更多对其成功有利害关系的贡献者 [我不再使用 MySql 进行任何工作])。