Csharp 如何防止创建的线程超过可用硬件线程数

发布于10月27日

我有下面的方法，用于通过 for each 文件创建不同的任务来初始化和启动日志(log)文件处理.在任务管理器中，我可以看到这个函数以这种方式创建了大约100个线程.

public async Task LogProcessing(DescriptorList files, CancellationToken ct)
{
    var tasks = new List<Task>();
    foreach (var file in files)
        tasks.Add(new Task(() =>
        {
            ParsingFile(file, ct);
        }));

    foreach (var task in tasks) { task.Start(); }
   
    await Task.WhenAll(tasks);       
}

How can I prevent creating more threads than the available number of hardware threads?个谢谢.

推荐答案

如果您使用的是.NET 6.0或更高版本，则可以使用Parallel.ForEachAsync()来执行此操作:

await Parallel.ForEachAsync(
    files,
    new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount, CancellationToken = ct },
    async (file, cancellation) =>
    {
        await Task.Run(() => ParsingFile(file, cancellation), cancellation);
    });

请注意，使用MaxDegreeOfParallelism = Environment.ProcessorCount将并发线程的数量限制为(逻辑)处理器计数.这实际上通常是默认设置，所以您可能根本不需要设置，但有些人可能希望这样做以保持清晰.

根据文档"一般情况下，您不需要修改此设置"，但在使用默认设置之前，您应该查看this answer from Theodor Zoulias.(我自己通常不使用默认设置).

我建议阅读the documentation on MaxDegreeOfParallelism，然后自己决定是否指定它.

根据TheodorZoulias下面的 comments ，你可以更简单地写成:

await Parallel.ForEachAsync(
    files,
    new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount, CancellationToken = cancelSource.Token },
    (file, cancellation) =>
    {
        ParsingFile(file, cancellation);
        return ValueTask.CompletedTask;
    });

然而，如果ParsingFile()本身就是async，您当然会使用第一个版本.