async .net 4.0

Question

का उपयोग कर डेटाटेबल लौटाएं मेरे पास एक तरीका है जो एक डेटाटेबल देता है। मैंने सोचा था कि .NET 4.0 का उपयोग करके मैं केवल एसिंक तर्क और डेटा लौटा सकता हूं। लेकिन यह कोड शून्य डेटाटेबल ऑब्जेक्ट देता है। कोई भी विचार इस कोड के साथ क्या गलत है।

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 के साथ async/await या उपयोग नहीं कर सकते सी # 4. यह सी # 5. थे CTPs जो .NET 4 के शीर्ष पर स्थापित में एक नई सुविधा है, लेकिन वहाँ निश्चित कीड़े हैं उन सीटीपी में - उनका उपयोग न करें। आपको .NET 4.5 के पूर्ण रिलीज़ संस्करण का उपयोग करना चाहिए, जिसमें सी # 5 कंपाइलर शामिल है। (यह सब विजुअल स्टूडियो 2012 में है।)

दूसरा, आप कार्य की गलत संपत्ति का उपयोग कर रहे हैं, क्योंकि कुओंग ले ने दिखाया था। Result संपत्ति Task<T> के परिणामस्वरूप आप कैसे प्राप्त करते हैं।

तीसरा, 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। साथ ही, सुनिश्चित करें कि आप 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); 
} 

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