IDbCommand 缺少 ExecuteReaderAsync

Question

我正在使用 .NET Core 2.0。我有以下函数调用IDbCommand.ExecuteReader

public async Task<IEnumerable<Widget>> ReadAllAsync(
    System.Data.IDbConnection databaseConnection,
    System.Data.IDbTransaction databaseTransaction)
{
    var commandText = "SELECT WidgetId, Name FROM Widget";

    // _databaseCommandFactory.Create returns an IDbCommand
    var command = this._databaseCommandFactory.Create(databaseConnection, databaseTransaction, commandText);

    using (var dataReader = command.ExecuteReader())
    {
        // iterate through the data reader converting a collection of Widgets (`IEnumerable<Widget>`)
    }
}

我收到警告

此异步方法缺少“等待”运算符，将同步运行。考虑使用 'await' 运算符来等待非阻塞 API 调用，或使用 'await Task.Run(...)' 在后台线程上执行 CPU 密集型工作。

我正在考虑按照警告中的建议将 command.ExecuteReader() 语句转换为 await Task.Run(() => command.ExecuteReader())。但我不确定这是正确的方法，我相信Task.Run(...) 是用于基于 CPU 的工作。这主要是 IO 工作。

所以我的问题是

1. Task.Run(...) 是正确的方法吗？
2. 如果没有，是否有其他解决方案？
3. 或者我应该暂时忽略警告并等到ExecuteReaderAsync 被添加到IDbCommand 接口？ （有这方面的计划吗？）

Answer 1

await 关键字允许方法异步运行。 async 关键字允许在方法中使用 await 关键字并协助管理返回。

在调用await 之前，该方法将同步运行。

所以所有这些都是同步运行的。在完成之前，它不会返回任何内容或在方法中移动。

public async Task<IEnumerable<Widget>> ReadAllAsync(
    System.Data.IDbConnection databaseConnection,
    System.Data.IDbTransaction databaseTransaction)
{
    var commandText = "SELECT WidgetId, Name FROM Widget";

    // _databaseCommandFactory.Create returns an IDbCommand
    var command = this._databaseCommandFactory.Create(databaseConnection, databaseTransaction, commandText);

    using (var dataReader = command.ExecuteReader())
    {
        // iterate through the data reader converting a collection of Widgets (`IEnumerable<Widget>`)
    }
}

通过转换为DbCommand，大多数IDbCommand 派生实现已经这样做，然后转换为DbCommand 并添加等待将起作用，例如

var dbCommand = (DbCommand) command;
using (var dataReader = await dbCommand.ExecuteReaderAsync())
{
    while (await dataReader.ReadAsync()) 
    {
        // iterate through the data reader converting a collection of Widgets (`IEnumerable<Widget>`)
    }
}

或创建一个单独的任务

public async Task MyAsyncMethod()
{
  // Do your stuff that takes a long time
}

public async Task CallMyAsyncMethod()
{
  // We can await Tasks, regardless of where they come from.
  await MyAsyncMethod();

}

这样 - 程序将在等待从该方法返回的同时继续运行，而不是锁定 UI 和其他所有内容。