C#怎么限制并发线程数量_C#如何使用线程池ThreadPool【高级技巧】-C#.Net教程-PHP中文网

threadpool.setmaxthreads 在 .net core/.net 5+ 中基本失效，线程池会自动扩容，强行设低值反致排队、延迟飙升甚至死锁；应使用 semaphoreslim 或 parallel.foreachasync 实现上层并发控制。

c#怎么限制并发线程数量_c#如何使用线程池threadpool【高级技巧】

ThreadPool.SetMaxThreads 在 .NET Core/.NET 5+ 中基本失效

直接调用 ThreadPool.SetMaxThreads 对大多数现代 .NET 应用（.NET Core 2.1+、.NET 5 及以上）没有实际限流效果。线程池会根据工作负载自动扩容，强行设低值反而导致任务排队、延迟飙升，甚至死锁。

真正可控的并发限制必须由上层逻辑实现，而非依赖线程池底层参数。

Windows 上 SetMaxThreads 仅影响“非 I/O 完成端口线程”（即 worker threads），但线程池会绕过该限制动态创建新线程
.NET Core 起已移除对 SetMinThreads 的强制约束，SetMaxThreads 仅作为软提示
高频短任务场景下，盲目调小最大线程数会导致 ThreadPool.GetAvailableThreads 返回值虚高，误判资源余量

用 SemaphoreSlim 控制并发数量最直接可靠

SemaphoreSlim 是专为异步并发控制设计的轻量同步原语，支持 await，无线程阻塞，适合 IO 密集型与混合型任务。

示例：限制最多 4 个 HTTP 请求同时发出：

"避开 C# 常见错误——空陷阱、异步陷阱、LINQ 陷阱及资源泄漏。"

下载

private static readonly SemaphoreSlim _semaphore = new SemaphoreSlim(4, 4);

public async Task<string> FetchAsync(string url)
{
    await _semaphore.WaitAsync(); // 等待许可
    try
    {
        using var client = new HttpClient();
        return await client.GetStringAsync(url);
    }
    finally
    {
        _semaphore.Release(); // 务必释放，建议用 try/finally
    }
}</string>

构造时第一个参数是初始许可数（即最大并发数），第二个是最大许可数（通常与之相等）
不要在静态构造函数或 Task.Run 中初始化 SemaphoreSlim，避免竞态
若需跨作用域复用，确保 SemaphoreSlim 实例生命周期足够长（如注入为 Singleton）

Parallel.ForEachAsync 是 .NET 6+ 推荐的批量并发方案

它内建并发度控制，比手写 Task.WhenAll + SemaphoreSlim 更简洁、更安全，且自动处理异常聚合与取消。

示例：并发处理 100 个文件，最多 8 个并行：

var files = Directory.GetFiles(@"C:\data", "*.log");
await Parallel.ForEachAsync(files, new ParallelOptions { MaxDegreeOfParallelism = 8 }, async (file, ct) =>
{
    var content = await File.ReadAllTextAsync(file, ct);
    await ProcessLogAsync(content, ct);
});

MaxDegreeOfParallelism 是硬性上限，不是目标值；低于该值时仍可能因调度策略短暂超发
不适用于需要精细顺序控制或结果按输入顺序返回的场景（此时应选 Task.WhenAll + 分批）
注意 Parallel.ForEachAsync 默认不捕获同步上下文，UI 线程中更新控件需显式 Dispatcher.Invoke 或 BeginInvoke