在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并返回结果。

现在它可能有点先进，但我认为这个答案可能是有用的，只是看看这可能是多么的干净。