企业官网建设流程全解析

async-sema vs p-limit vs p-queue：Node.js 并发控制库终极对比与选型指南

【免费下载链接】async-semaSemaphore using `async` and `await`项目地址: https://gitcode.com/gh_mirrors/as/async-sema

在 Node.js 项目里，并发控制库是守护数据库连接、第三方 API 与接口稳定性的重要工具。面对 async-sema、p-limit、p-queue 这三款主流 Node.js 并发控制库，很多开发者都会陷入选择困难：它们到底有什么区别？各自的优缺点是什么？本文将从设计理念、核心 API、性能与适用场景四个维度展开全方位对比，并给出一份可以直接照抄的选型指南。

为什么你需要一个并发控制库？

先看一个真实痛点：当你用Promise.all一次性发起上百个请求时，数据库连接池会瞬间被打满，第三方 API 会返回 429，甚至拖垮整个进程。所谓并发控制，就是限制同一时刻最多只能有 N 个任务在运行，其余任务排队等待。

三款库解决的正是这个问题，但思路截然不同：

async-sema：基于信号量的并发控制

async-sema 是 Vercel 开源的信号量实现，它的核心 API 只有两个：acquire()获取令牌、release()释放令牌。令牌数就是最大并发数。

async-sema 信号量实现并发控制的完整用法

const { Sema } = require('async-sema'); // 最多允许 4 个并发任务 const s = new Sema(4); async function fetchData(url) { await s.acquire(); // 拿不到令牌就在这里等待 try { // 执行业务逻辑 } finally { s.release(); // 别忘了释放，建议放在 finally } } await Promise.all(urls.map(fetchData));

与普通计数器信号量不同，async-sema 用「令牌列表」而非单一数字管理并发数，这带来了两个杀手级特性：

1️⃣ 资源池管理：通过initFn让每个令牌代表一个真实资源（比如 Redis 连接），获取令牌即获取连接，实现优雅的连接池。实战示例见examples/pooling.js。

2️⃣ 背压控制：通过pauseFn/resumeFn，当等待队列过长时主动暂停数据流（比如暂停 readline 读取），防止内存被堆积的 Promise 撑爆。实战示例见examples/pausing.js。

此外，tryAcquire()可以非阻塞地尝试获取令牌，nrWaiting()可以实时查询排队人数，drain()可以优雅回收所有令牌——非常适合进程退出前清理连接。

async-sema 自带 RateLimit 速率限制

async-sema 还内置了一个基于信号量的速率限制器，无需额外引入其他库：

const { RateLimit } = require('async-sema'); const lim = RateLimit(5); // 每秒最多 5 次调用 for (let i = 0; i < n; i++) { await lim(); // 执行受速率限制的操作 }

通过{ timeUnit, uniformDistribution }选项，还能自定义时间窗口，或让请求在时间轴上均匀分布，实测示例见examples/rate-limiting.js。

p-limit：极致轻量的并发限制器

p-limit 压缩后仅几十字节，零依赖，理念只有一个：把并发数限制起来。

import limit from 'p-limit'; const limiter = limit(2); // 同时最多执行 2 个任务 const run = limiter(async () => { // 你的异步任务 }); await Promise.all(tasks.map(() => run()));

它可以通过limiter.activeCount查看当前活跃任务数、limiter.pendingCount查看排队数，还能用clearQueue()清空队列。如果你只是想让「一堆请求不要同时发出去」，p-limit 是零学习成本的选择。

p-queue：功能最全的 Promise 任务队列

p-queue 不止限制并发，而是一个完整的任务队列系统：

import PQueue from 'p-queue'; const queue = new PQueue({ concurrency: 2 }); queue.add(async () => { /* 任务 A */ }, { priority: 10 }); queue.add(async () => { /* 任务 B */ }, { priority: 1 });

它独有的高级特性包括：任务优先级、任务超时、pause()/start()暂停恢复队列、idle/active事件监听，以及 FIFO / LIFO 队列模式切换。代价是包体积和心智负担明显更大。

三大并发控制库对比一览表

并发控制库选型指南：什么场景选什么

场景一：只是限制请求并发数

推荐p-limit。比如批量调用第三方 API、批量爬虫，一行limit(n)搞定，几乎无学习成本。

场景二：需要连接池与速率限制

推荐async-sema。用initFn管理数据库 / Redis 连接池，用RateLimit限制调用频率，一个库解决两个问题，还能用drain()优雅关闭连接。

场景三：复杂任务调度

推荐p-queue。任务有优先级、需要暂停恢复、要监听队列状态时，p-queue 的功能最全。

场景四：流式数据处理防内存溢出

推荐async-sema。它的pauseFn/resumeFn背压机制是另外两个库没有的，非常适合逐行解析大文件等场景。

三步安装并验证 async-sema

1️⃣ 安装依赖：

npm install --save async-sema

2️⃣ 编写测试用例，参考test/sema.test.ts中的场景，确认tryAcquire()、nrWaiting()等行为符合预期。

3️⃣ 在生产代码中，记得把release()放进finally，避免异常导致令牌泄漏。

需要本地调试源码时，可以通过git clone https://gitcode.com/gh_mirrors/as/async-sema拉取仓库，核心实现集中在src/index.ts，测试与示例分别在test/sema.test.ts和examples/目录下。

总结

• 想要最轻量：选 p-limit；
• 想要最全能：选 p-queue；
• 想要信号量、连接池、限速、背压一站式解决：选 async-sema。

理解了三款 Node.js 并发控制库的差异，你就能在项目中做出最合适的选型。记住：并发控制不是越复杂越好，贴合业务场景的才是最好的。

【免费下载链接】async-semaSemaphore using `async` and `await`项目地址: https://gitcode.com/gh_mirrors/as/async-sema