惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

GbyAI
GbyAI
N
News and Events Feed by Topic
D
DataBreaches.Net
MongoDB | Blog
MongoDB | Blog
CTFtime.org: upcoming CTF events
CTFtime.org: upcoming CTF events
freeCodeCamp Programming Tutorials: Python, JavaScript, Git & More
Engineering at Meta
Engineering at Meta
T
Tailwind CSS Blog
博客园_首页
Microsoft Azure Blog
Microsoft Azure Blog
Y
Y Combinator Blog
博客园 - Franky
Hugging Face - Blog
Hugging Face - Blog
月光博客
月光博客
A
About on SuperTechFans
I
InfoQ
S
Securelist
Last Week in AI
Last Week in AI
S
Schneier on Security
C
CXSECURITY Database RSS Feed - CXSecurity.com
Hacker News: Ask HN
Hacker News: Ask HN
Schneier on Security
Schneier on Security
Know Your Adversary
Know Your Adversary
腾讯CDC
大猫的无限游戏
大猫的无限游戏
S
Security @ Cisco Blogs
博客园 - 三生石上(FineUI控件)
Simon Willison's Weblog
Simon Willison's Weblog
D
Darknet – Hacking Tools, Hacker News & Cyber Security
T
Tor Project blog
美团技术团队
aimingoo的专栏
aimingoo的专栏
G
Google Developers Blog
罗磊的独立博客
Vercel News
Vercel News
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
Threat Intelligence Blog | Flashpoint
Threat Intelligence Blog | Flashpoint
The Cloudflare Blog
S
Secure Thoughts
www.infosecurity-magazine.com
www.infosecurity-magazine.com
Latest news
Latest news
Recent Announcements
Recent Announcements
Exploit-DB.com RSS Feed
Exploit-DB.com RSS Feed
cs.CV updates on arXiv.org
cs.CV updates on arXiv.org
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
L
LINUX DO - 热门话题
Security Latest
Security Latest
TaoSecurity Blog
TaoSecurity Blog
Cyberwarzone
Cyberwarzone
有赞技术团队
有赞技术团队

博客园 - 邓磊Lei

为什么 Go 一个 HTTP 服务可以同时处理数万连接 gin怎么处理一次http请求的 我的经验:git提交信息分别用什么icon C# 也能像 Python 一样写脚本 | .NET 10 构建基于文件的应用 .NET 10 使用 Microsoft.AspNetCore.OpenApi 实现 API 版本管理 ASP.NET Core 内存缓存实战:一篇搞懂该怎么配、怎么避坑 Microsoft Agent Framework + Kimi API 实战:控制台应用跑通单次与多轮 Agent 对话 开发实战:asp.net core + ef core 实现动态可扩展的分页方案 聊聊 ASP.NET Core 中间件和过滤器的区别 Python 入门:从“其他语言”到 Pythonic 思维的完整迁移手册 .NET 进阶之路:异步、并发与内存管理的系统性认知 Redis:延迟双删的适用边界与落地细节 Serilog:从结构化日志认知到 .NET 工程落地 EF Core 原生 SQL 实战:FromSql、SqlQuery 与对象映射边界 EF Core 拦截器实战:SaveChangesInterceptor、CommandInterceptor 与审计落地 ASP.NET Core 外部依赖调用治理实战:HttpClientFactory、Polly 与幂等边界 .NET .Result 避坑指南:不同框架下的死锁与线程池饥饿 EF Core 慢查询排查实战:TagWith、OpenTelemetry、执行计划,30 分钟定位性能瓶颈 EF Core 并发冲突实战:乐观锁、RowVersion 与 DbUpdateConcurrencyException 怎么处理 EF Core 写入链路深拆:从 ChangeTracker 到 SQL Batch 的性能诊断与优化 ASP.NET Core 认证鉴权实战:JWT、Policy 与权限边界怎么落地 EF Core 查询性能黑洞:Include、投影与跟踪策略的边界 从 IApplicationBuilder 到 RequestDelegate:ASP.NET Core 请求管线的性能与可观测性实战 如何在 rider 中配置 SonarQube
C# 异步编程深水区:Task、ValueTask、线程池饥饿与背压设计
邓磊Lei · 2026-03-10 · via 博客园 - 邓磊Lei

接口慢,不一定是数据库慢。很多系统在高峰期的核心问题,是异步链路写法导致线程池被慢慢耗空。

这类问题最麻烦的地方在于:

  • CPU 不一定打满
  • 错误日志不一定明显
  • 本地压测可能复现不出来

这篇文章围绕一个目标展开:让异步代码在高并发下“稳态运行”,而不是“平时很快,高峰崩盘”。

1. 问题背景:为什么会出现线程池饥饿

常见触发方式:

  • 在 ASP.NET Core 请求中使用 .Result / .Wait()
  • 把 I/O 任务包进 Task.Run
  • 下游服务抖动时无限制并发重试

你以为是在“提速”,实际上是在制造排队。

2. 原理解析

2.1 Task 与调度

Task 表示异步操作,不等于“新线程”。多数场景下,它复用线程池线程在不同 I/O 等待阶段切换。

2.2 ValueTask 的边界

ValueTask 适合高频且经常同步完成的路径,减少分配;但它有使用约束,不应随意替换所有 Task

2.3 线程池饥饿

当大量请求线程被阻塞等待 I/O,线程池补充速度跟不上时,后续请求只能排队,RT 开始抖动。

2.4 背压

背压本质是“主动限制进入系统的工作量”,通过队列边界和并发上限把峰值削平,换取整体稳定。

3. 示例代码:有边界的后台处理模型

下面是一个可落地的最小模型:Channel + 有界队列 + 固定并发消费者。

using System.Threading.Channels;

public sealed record ExportJob(Guid JobId, long UserId, DateTime CreatedAt);

public sealed class ExportQueue
{
    private readonly Channel<ExportJob> _channel = Channel.CreateBounded<ExportJob>(
        new BoundedChannelOptions(500)
        {
            FullMode = BoundedChannelFullMode.DropWrite,
            SingleWriter = false,
            SingleReader = false
        });

    public bool TryEnqueue(ExportJob job) => _channel.Writer.TryWrite(job);
    public IAsyncEnumerable<ExportJob> ReadAllAsync(CancellationToken ct) => _channel.Reader.ReadAllAsync(ct);
}

public sealed class ExportWorker : BackgroundService
{
    private readonly ExportQueue _queue;
    private readonly ILogger<ExportWorker> _logger;
    private readonly SemaphoreSlim _concurrency = new(4);

    public ExportWorker(ExportQueue queue, ILogger<ExportWorker> logger)
    {
        _queue = queue;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        await foreach (var job in _queue.ReadAllAsync(stoppingToken))
        {
            _ = ProcessOneAsync(job, stoppingToken);
        }
    }

    private async Task ProcessOneAsync(ExportJob job, CancellationToken ct)
    {
        await _concurrency.WaitAsync(ct);
        try
        {
            await Task.Delay(200, ct); // 模拟 I/O
            _logger.LogInformation("export done {JobId}", job.JobId);
        }
        catch (OperationCanceledException)
        {
            // 正常退出
        }
        finally
        {
            _concurrency.Release();
        }
    }
}

API 层只负责入队,不直接做重任务:

app.MapPost("/api/exports", (ExportQueue queue, long userId) =>
{
    var job = new ExportJob(Guid.NewGuid(), userId, DateTime.UtcNow);
    return queue.TryEnqueue(job)
        ? Results.Accepted($"/api/exports/{job.JobId}", new { job.JobId })
        : Results.StatusCode(StatusCodes.Status429TooManyRequests);
});

4. 工程实践建议

4.1 异步红线

  • 请求链路禁用 .Result / .Wait()
  • I/O 场景禁用 Task.Run 伪异步
  • 所有下游调用必须设置超时与取消令牌

4.2 并发控制前置

把限流和队列边界放在入口层,不要等到数据库或第三方 API 才发现过载。

4.3 监控维度

至少监控:

  • 线程池可用线程数
  • 队列长度
  • 请求超时率
  • 重试次数

4.4 ValueTask 使用准则

只在以下条件同时满足时使用:

  • 方法调用极高频
  • 同步完成概率高
  • 团队理解其使用约束

否则优先 Task,维护成本更低。

5. 总结

异步编程的核心不是“把方法都改成 async”,而是把系统并发控制住。

当你用有界队列、固定并发、超时取消把流量压在可承载区间,线程池饥饿就不会轻易出现。稳定性,永远比一次压测峰值更有工程价值。