6

我有一个返回数据表的方法。我认为使用 .net 4.0 我可以异步逻辑并返回数据。但是此代码返回 null Datatable 对象。任何想法此代码有什么问题。

public DataTable GetData(string sql, string connectionName)
{
    DataTable dt = (DataTable)GetDataAsync(sql, connectionName).AsyncState;
    return dt;
}

private async Task<DataTable> GetDataAsync(string sql, string connectionName)
{
    return await TaskEx.Run(() => { return FillData(sql, connectionName); });
}

private DataTable FillData(string sql, string connectionName)
{
    SqlConnection conn = _connections.Where(w => w.ConnectionName == connectionName).Single().Connection;
    SqlDataAdapter adp = new SqlDataAdapter(sql, conn);
    DataSet ds = new DataSet();

    adp.Fill(ds);

    return ds.Tables[0];
}
4

3 回答 3

10

首先，您不能将async/await与 .NET 4 或 C# 4 一起使用。这是 C# 5 中的一项新功能。在 .NET 4 之上安装了 CTP，但这些 CTP 中有明确的错误 -不要使用它们. 您应该使用 .NET 4.5 的完整发行版，其中包括 C# 5 编译器。（所有这些都在 Visual Studio 2012 中。）

其次，正如 Cuong Le 所示，您使用了错误的任务属性。该Result属性是您如何获得 a 的结果Task<T>。

第三，在进行更改以使用该Result属性后，您将阻止获取表 - 使其毫无意义。这个：

public DataTable GetData(string sql, string connectionName)
{
    DataTable dt = (DataTable)GetDataAsync(sql, connectionName).Result;
    return dt;
}

...在很大程度上等同于：

public DataTable GetData(string sql, string connectionName)
{
    return FillData(sql, connectionName);
}

如果您要启动一个任务并立即等待它，您不妨同步调用该方法。

于 2012-09-26T06:00:55.253 回答
8

我自己的源代码。

public static async Task<DataTable> GetDataTableAsync(this System.Data.Common.DbCommand command, CancellationToken cancellationToken, string tableName = null)
    {
        TaskCompletionSource<DataTable> source = new TaskCompletionSource<DataTable>();
        var resultTable = new DataTable(tableName ?? command.CommandText);
        DbDataReader dataReader = null;

        if (cancellationToken.IsCancellationRequested == true)
        {
            source.SetCanceled();

            await source.Task;
        }

        try
        {
            await command.Connection.OpenAsync();
            dataReader = await command.ExecuteReaderAsync(CommandBehavior.Default);
            resultTable.Load(dataReader);
            source.SetResult(resultTable);
        }
        catch (Exception ex)
        {
            source.SetException(ex);
        }
        finally
        {
            if (dataReader != null)
                dataReader.Close();

            command.Connection.Close();
        }

        return resultTable;
    }
于 2014-06-25T03:02:28.623 回答
3

如果您想使用async代码，请不要阻止它。此外，请确保您使用的是Async Targeting Pack而不是 Async CTP。

private async Task<DataTable> GetDataAsync(string sql, string connectionName)
{
  return await TaskEx.Run(() => { return FillData(sql, connectionName); });
}

private async GetAndProcessDataAsync()
{
  DataTable table = await GetDataAsync("my sql", "my connection name");
  ProcessData(table);
}
于 2012-09-26T13:22:43.517 回答