不能得到Task.Result返回字符串，除非我添加一個Thread.Sleep

Question

第一次在這裏問一個問題，我會盡量做到儘可能具體。

我正在使用基於Web的Api工作，我很難得到任務以返回結果。

我有一個貿易類這樣與一個買方法和一個GetOrderNumber方法。在我的MainForm中，我使用任務來執行交易，然後檢索與該交易相關的訂單號。

NewTrade Test = new NewTrade(); 

Task<string> tmp = Task.Factory.StartNew(() => Test.Buy("JPM.NY", 100, 59.50)); 
string reqid = tmp.Result; 

Task<string> tmp2 = Task.Factory.StartNew(() => Test.GetOrderNumber(reqid)); 

Console.WriteLine(tmp2.Result); 

第一個任務返回一個REQID號碼。第二項任務使用REQID號碼並返回交易放置的實際訂單編號。

我遇到的問題是我從第一個任務獲得ReqID號碼，但是我在第二個任務中返回空白。

但是，如果我在第一個和第二個任務之間添加一個Thread.sleep（），我會得到訂單號。

我使用任務因爲最終會有數百個訂單被放置，所以每個訂單都有訂單號碼至關重要。

class NewTrade 
{ 
    public string Buy(string stkName, int stkShares, double limitPrice) 
    { 
     try 
     { 
      using (MyWebClient client = new MyWebClient()) 
      { 

       Stream data = client.OpenRead("http://localhost:8080/ExecuteOrder?symbol=" + stkName + "&limitprice=" + limitPrice + "&ordername=ARCA%20Buy%20ARCX%20Limit%20DAY&shares=" + stkShares); 
       StreamReader reader = new StreamReader(data); 
       string s = reader.ReadToEnd(); 
       s = getBetween(s, "<Content>", "</Content>"); //this is a util function to parse the result 
       // MessageBox.Show(s.ToString()); 
       data.Close(); 
       reader.Close(); 

       return s; 
      } 
     } 
     catch (WebException e) 
     { 
      Console.WriteLine(e.Message); 
      Console.WriteLine(e.StackTrace); 
      return "Nothing"; 
     } 
    } 

    public string GetOrderNumber(string id) 
    { 
     string s = ""; 

     using (MyWebClient client = new MyWebClient()) 
     { 
      try 
      { 
       WebRequest request = WebRequest.Create("http://localhost:8080/GetOrderNumber?requestid=" + id); 
       WebResponse response = request.GetResponse(); 
       var reader = new StreamReader(response.GetResponseStream()); 

       s = reader.ReadToEnd(); 
       Console.WriteLine(s); 
       return s; 
      } 
      catch (Exception ex) 
      { 
       Console.WriteLine(ex.ToString()); 
       return ""; 
      } 
     } 
    } 
} 

Answer 1

使用Task S能夠使應用程序更具有可擴展性要啓用線程來處理其他任務而異步任務正在進行中。也就是說，使用Task.Run或Task.Factory.StartNew在後臺執行IO任務會失敗該目的。您需要通過調用您正在使用的IO構造的async API來使您的方法真正成爲async。試着改變你的代碼是這樣的：

public Task<string> MakeTradeAsync() 
{ 
    NewTrade Test = new NewTrade(); 

    string reqid = await Test.Buy("JPM.NY", 100, 59.50); 

    string orderNumber = await Test.GetOrderNumber(reqid); 

    Console.WriteLine(orderNumber); 

    return orderNumber; 
} 

這需要你做出Test.Buy和Test.GetOrderNumber異步爲好。您可以通過使用async API來訪問您的服務器數據。

public async Task<string> Buy(string stkName, int stkShares, double limitPrice) 
{ 
    try 
    { 
     using (MyWebClient client = new MyWebClient()) 
     { 
      // use async API here to get the data, assuming existance of OpenReadAsync 
      Stream data = await client.OpenReadAsync("http://localhost:8080/ExecuteOrder?symbol=" + stkName + "&limitprice=" + limitPrice + "&ordername=ARCA%20Buy%20ARCX%20Limit%20DAY&shares=" + stkShares); 
      StreamReader reader = new StreamReader(data); 
      string s = reader.ReadToEnd(); 
      s = getBetween(s, "<Content>", "</Content>"); //this is a util function to parse the result 
      // MessageBox.Show(s.ToString()); 
      data.Close(); 
      reader.Close(); 

      return s; 
     } 
    } 
    catch (WebException e) 
    { 
     Console.WriteLine(e.Message); 
     Console.WriteLine(e.StackTrace); 
     return "Nothing"; 
    } 
} 

public async Task<string> GetOrderNumber(string id) 
{ 
    string s = ""; 

    using (MyWebClient client = new MyWebClient()) 
    { 
     try 
     { 
      WebRequest request = WebRequest.Create("http://localhost:8080/GetOrderNumber?requestid=" + id); 
      WebResponse response = await request.GetResponseAsync(); 
      var reader = new StreamReader(response.GetResponseStream()); 

      s = await reader.ReadToEndAsync(); 
      Console.WriteLine(s); 
      return s; 
     } 
     catch (Exception ex) 
     { 
      Console.WriteLine(ex.ToString()); 
      return ""; 
     } 
    } 
}