在C＃中進行線程調用

Question

我是c＃線程世界的新手。我讀過有不同的方式來執行線程，如順序。

我的場景如下。哪一個更適合以下。

我有複雜的對象列表。我將分別爲每個對象[put的主體]調用PUT端點。列表中可能有1000個或更多的對象。我無法將所有對象都傳遞給一個對象，因此我必須在每次調用put對象時傳遞每個對象。這樣，如果有1000個對象，我必須分別撥打1000個電話。

每次撥打電話都是相互獨立的，而我必須存儲每次通話回覆的屬性。

我正在考慮將線程概念應用到上面，但不確定哪一個以及如何去做。

任何建議將不勝感激。

預先感謝。

根據以下評論， 將方法簽名放在此處並添加更多詳細信息。我有IEnumerable<CamelList>。對於每個駱駝來說，我必須做出一個put請求調用，並從每個調用的響應中更新表格。我會寫一個新的方法來接受這個列表，並使用下面的2個方法來調用和更新表。我必須確保，我同時進行的呼叫次數不超過100次，並且我打電話的API可以每分鐘100次由同一用戶呼叫。

我們有一個方法 public Camel SendRequest(handler, uri, route, Camel); //basically takes all the parameters and provide you the Camel.

我們有一個方法public void updateInTable(Entity Camel); //updates the table.

Answer 1

HTTP調用使用HttpClient class，其HTTP方法已經異步通常由。您不需要創建自己的線程或任務。

所有異步方法返回一個Task或Task<T> value. You need to use the等待keyword to await for the operation to complete asynchronously - that means the thread is released until the operation completes. When that happens, execution resumes after the等待。

您可以看到如何編寫PUT請求here。該示例使用PutAsJsonAsync方法來減少序列化Product類轉換成字符串所需的樣板代碼，並創建一個StringContent類與正確的內容類型，例如：

var response = await client.PutAsJsonAsync($"api/products/{product.Id}", product); 
response.EnsureSuccessStatusCode(); 

如果你想要把1000級的產品，你需要的是一個數組或列表中的產品。您可以使用LINQ進行多個呼叫，等待他們的任務返回結尾：

var callTasks = myProducts.Select(product=>client.PutAsJsonAsync($"api/products/{product.Id}", product); 
var responses = await Task.WhenAll(callTasks); 

這意味着你必須等待所有請求完成之前，你可以檢查有沒有人成功。你可以改變的Select身體等待響應本身：

var callTasks = myProducts.Select(async product=>{ 
     var response=await client.PutAsJsonAsync($"api/products/{product.Id}", product); 
     if (!response.IsSuccessStatusCode) 
     { 
      //Log the error     
     } 
     return response.StatusCode; 
}); 
var responses=await Task.WhenAll(callTasks); 

這是更好地雖然CONVER拉姆達到一個單獨的方法，如PutProductAsync：

async Task<HttpStatusCode> PutProduct(Product product,HttpClient client) 
{ 
      var response=await client.PutAsJsonAsync($"api/products/{product.Id}", product); 
      if (!response.IsSuccessStatusCode) 
      { 
       //Log the error     
      } 
      return response.StatusCode; 
}; 

var callTasks = myProducts.Select(product=>PutProductAsync(product)); 
var responses=await Task.WhenAll(callTasks); 

Answer 2

我會用暗示微軟對此的反應框架。你需要NuGet「System.Reactive」來獲取這些位。

然後就可以做到這一點：

var urls = new string[1000]; //somehow populated; 

Func<string, HttpContent, IObservable<string>> putCall = (u, c) => 
    Observable 
     .Using(
      () => new HttpClient(), 
      hc => 
       from resp in Observable.FromAsync(() => hc.PutAsync(u, c)) 
       from body in Observable.FromAsync(() => resp.Content.ReadAsStringAsync()) 
       select body); 

var callsPerTimeSpanAllowed = 100; 
var timeSpanAllowed = TimeSpan.FromMinutes(1.0); 

IObservable<IList<string>> bufferedIntervaledUrls = 
    Observable.Zip(
     Observable.Interval(timeSpanAllowed), 
     urls.ToObservable().Buffer(callsPerTimeSpanAllowed), 
     (_, buffered_urls) => buffered_urls); 

var query = 
    from bufferedUrls in bufferedIntervaledUrls 
    from url in bufferedUrls 
    from result in putCall(url, new StringContent("YOURCONTENTHERE")) 
    select new { url, result }; 

IDisposable subscription = 
    query 
     .Subscribe(
      x => { /* do something with each `x.url` & `x.result` */ }, 
      () => { /* do something when it is all finished */ }); 

該代碼被打破網址成塊（或緩衝器）100，並把它們放在開1分鐘的時間線（或間隔）。然後它會爲每個URL調用putCall並返回結果。

現在它可能有點先進，但我認爲這個答案可能是有用的，只是看看這可能是多麼的乾淨。