在 Parallel.foreach 中等待 [重复]

Posted 2023-05-07

【中文标题】在 Parallel.foreach 中等待 [重复]

【英文标题】：await in Parallel.foreach [duplicate]

【发布时间】：2013-04-04 16:17:12

【问题描述】：

我有一个将在 Parallel.Foreach 中使用的异步方法。在异步方法中有等待任务。 但是，在测试中，似乎没有等待行为，等待任务没有完成。有什么问题？下面是代码。

public void method1()

  Ilist<string> testList = new IList<string>()"1","2","3";
  Parallel.ForEach(testList, ()=>
  
       method2();
  );

public async void method2()

   await Task.run(()=>  some other codes here );  

【问题讨论】：

这是这个问题的措辞更好的问题，但它的欺骗有最好的答案：***.com/a/11565317/176877

不是这样：代码示例表明 OP 关于 async-await 和 TPL 的假设从一开始就存在缺陷，只会混淆问题。

【参考方案1】：

回答晚了，但您似乎正在尝试并行执行 CPU 密集型工作，而不是异步执行 I/O 密集型工作。 Parallel.ForEach 负责你的并行性，所以不需要 Task.Run，​​async/await 在这里没有任何收获。我建议从 method2 中删除这些位，因此整个事情简化为：

public void method1()

    Ilist<string> testList = new IList<string>()"1","2","3";
    Parallel.ForEach(testList, ()=>
    
        method2();
    );

public void method2()

    // some other (plain old synchronous) code here

【参考方案2】：

void async 方法是“一劳永逸”，没有办法等待它们完成。在您的并行循环中调用 method2 时，它会立即返回，因此您的循环仅确保在循环完成之前创建 method2 中的任务。

您可以将method2 的返回类型更改为Task，这将允许您等待操作的结果，例如

public async Task method()

     await Task.Run(()  some other code here );

你可以在循环中等待

method2().Wait();

虽然这样做并不比直接在你的 foreach 委托中运行 method2 中的任务主体更好。

【讨论】：

是的，你是对的，它有效。我必须在 method2 中运行的原因是因为我必须将不同的 Func 传递给 method1。如创建、删除等。非常感谢。