async .net 4.0を使用してDataTableを返す

Question

データテーブルを返すメソッドがあります。私は.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]; 
} 

Answer 1

まず、あなたはそれは.NET 4の上にインストールのCTPがあったのC＃5の新機能ですが、明確なバグがある.NET 4またはC＃4でasync/awaitを使用することはできませんそれらのCTPでは - はを使用しないでください。 C＃5コンパイラを含む.NET 4.5のフルリリース版を使用する必要があります。 （これはVisual Studio 2012にあります）

第2に、Cuong Leが示したように、タスクの間違った特性を使用しています。 Resultプロパティは、Task<T>の結果をどのように取得するかです。

第3に、Resultプロパティを使用するように変更した後、テーブルがフェッチされるのをブロックして、無意味にします。この：

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

タスクを起動し、すぐにそれを待つつもりなら、あなたにもちょうど同期メソッドを呼び出すことができます：

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

は...とほぼ同等です。

Answer 2

asyncコードを使用する場合は、don't block on itです。また、非同期CTPではなくAsync Targeting Packを使用していることを確認してください。

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); 
} 

Answer 3

私自身のソースコードです。

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; 
    }