实际的最大并行任务。

Question

我希望此代码要执行1秒钟：

public async void Test()
{
    DateTime start = DateTime.Now;
    await Parallel.ForEachAsync(new int[1000], new ParallelOptions { MaxDegreeOfParallelism = 1000 }, async (i, token) =>
    {
        Thread.Sleep(1000);
    });
    Console.WriteLine("End program: " + (DateTime.Now - start).Seconds + " seconds elapsed.");
}

相反，在我的PC上需要37秒（i7-9700 8核8-thread）：

End program: 37 seconds elapsed.

我正在使用MaxDegreeofParallelism = 1000生成1000个任务。 ...为什么他们都不同时运行？

Answer 1

方法调用异步body threadpool 线程。通常，此委托会迅速返回valuettask，但是在您的情况下，这不是发生的情况，因为您的代表并不是真正的异步：

async (i, token) => Thread.Sleep(1000);

您可能会在这里发出编译器警告，关于async 缺少等待运算符的方法。但是，将混合的同步/异步工作负载给并行。foreachAsync方法还可以。此方法旨在处理任何类型的工作量。但是，如果工作负载主要是同步的，则可能是饱和的threadpool。

threadpool已经创建了 emovention.processorcount ，并且需要做更多的工作。在这种情况下，threadpool切换到保守的算法，该算法每秒都会创建一个新线程（截至.NET 6）。这种行为不会精确记录，并且可能会在未来的.NET版本中改变。

为了获得所需的行为，即在所有1000个输入中运行委托，您必须增加threadpool立即根据需求创建的线程数：

ThreadPool.SetMinThreads(1000, 1000); // At the start of the program

有些人会这样做之后，您将不再有一个线程池，因为一个线程池意味着是一小池可重复使用的线程。但是，如果您不在乎语义，而只想完成工作，那么无论后果如何-c-sharp-extly-1-mb“>内存消耗在操作系统级别上的开销，这是解决问题的最简单方法。

Answer 2

我不知道foreachAsync的确切实现，但我假设他们使用task s，而不是thread s。

当您使用1000 任务 s运行1000 CPU绑定操作时，实际上并未创建1000 thread s，您只是在问一些thread> threadpool 线程 s运行这些操作。这些线程 s被Sleep调用阻止，因此大多数任务 s在开始执行之前被排队。

这就是为什么在任务中或一般的异步上下文中调用thread.sleep是一个可怕的想法的原因。如果您编辑代码以异步而不是同步等待，那么经过的时间可能会更接近一秒钟。

await Parallel.ForEachAsync(new int[1000], new ParallelOptions { MaxDegreeOfParallelism = 1000 }, async (i, token) =>
{
    await Task.Delay(1000);
});