.net Core Parallel.ForEach问题
我已经切换到.net Core进行了一些项目，现在我遇到了Parallel.ForEach的问题。 在过去，我经常有一个id值列表，然后我会用它来发送Web请求以获取完整数据。 它看起来像这样：
Parallel.ForEach(myList, l => { // make web request using l.id // process the data somehow }); 好吧，在.net Core中，Web请求必须全部被标记为await ，这意味着必须使用async标记Parallel.ForEach操作。 但是，将Parallel.ForEach操作标记为async意味着我们有一个void async方法会导致问题。 在我的特殊情况下，这意味着响应在并行循环中的所有Web请求完成之前返回到应用程序，这既尴尬又导致错误。
问题：在这里使用Parallel.ForEach有哪些替代方案？
我发现一个可能的解决方案是将Parallel循环包装在Task中并等待任务：
await Task.Run(() => Parallel.ForEach(myList, l => { // stuff here }));
（在这里找到： Parallel.ForEach vs Task.Run和Task.WhenAll ）
但是，这对我不起作用。 当我使用它时，我仍然在循环完成之前返回应用程序。
另外一个选项：
var tasks = new List(); foreach (var l in myList) { tasks.Add(Task.Run(async () => { // stuff here })); } await Task.WhenAll(tasks);
这似乎有效，但这是唯一的选择吗？ 似乎新的.net Core已经使Parallel.ForEach几乎无用（至少在嵌套Web调用时）。
任何帮助/建议表示赞赏。
这3个apporaches都不好。
在此方案中，不应使用Parallel类或Task.Run 。
相反，有一个async处理程序方法：
private async Task HandleResponse(Task gettingResponse) { HttpResponseMessage response = await gettingResponse; // Process the data }
然后使用Task.WhenAll ：
Task[] requests = myList.Select(l => SendWebRequest(l.Id)) .Select(r => HandleResponse(r)) .ToArray(); await Task.WhenAll(requests);
为什么Parallel.ForEach不适合这个任务在注释中解释：它是为CPU绑定（CPU密集型）任务而设计的。 如果你将它用于IO绑定操作（比如发出web请求） – 你会在等待响应时浪费线程池线程，没有任何好处。 它仍然可以使用它，但它不适合这种情况。
你需要的是使用异步Web请求方法（如HttpWerRequest.GetResponseAsync），但这里有另一个问题 – 你不想一次执行所有的web请求（如另一个答案所示）。 您的列表中可能有数千个url（ID）。 因此，您可以使用为此设计的线程同步构造，例如Semaphore 。 Semaphore就像队列一样 – 它允许X线程通过，其余的应该等到其中一个繁忙线程完成它的工作（稍微简化一下）。 这是一个例子：
static async Task ProcessUrls(string[] urls) { var tasks = new List(); // semaphore, allow to run 10 tasks in parallel using (var semaphore = new SemaphoreSlim(10)) { foreach (var url in urls) { // await here until there is a room for this task await semaphore.WaitAsync(); tasks.Add(MakeRequest(semaphore, url)); } // await for the rest of tasks to complete await Task.WhenAll(tasks); } } private static async Task MakeRequest(SemaphoreSlim semaphore, string url) { try { var request = (HttpWebRequest) WebRequest.Create(url); using (var response = await request.GetResponseAsync().ConfigureAwait(false)) { // do something with response } } catch (Exception ex) { // do something } finally { // don't forget to release semaphore.Release(); } }
您应该使用ref关键字调用方法来完成工作，并且应该尽可能少地完成工作。 在类似情况下，这种方法对我很有用。
Parallel.ForEach(myList, l => { // make web request using ref l.id string id=l.id; WebRequest webRequest= MakeRequest(ref id); // process the data somehow }); private WebRequest MakeRequest(ref string id) { //make and return web request }