0

0

如何在 p-limit 中实时监控并发任务进度并显示剩余请求数

花韻仙語

花韻仙語

发布时间:2026-02-11 23:42:37

|

414人浏览过

|

来源于php中文网

原创

如何在 p-limit 中实时监控并发任务进度并显示剩余请求数

本文详解如何利用 p-limit 的 `pendingcount` 属性实现任务进度可视化,通过定时轮询动态计算并输出“还剩 n 个 api 请求未完成”,适用于 cli 工具或后台任务监控场景。

p-limit 是一个轻量但强大的并发控制工具,它通过 limit(fn) 包装异步函数,确保任意时刻最多只有指定数量(如 pLimit(3))的任务在执行中。其暴露的 .pendingCount 属性是理解当前执行状态的关键:它表示当前已提交但尚未开始执行(即处于等待队列中)的任务数量——注意,它不包含正在运行中的任务(.running),也不包含已完成任务。

要实现类似 “我们还剩 n 个 API 调用未发起” 的实时提示,核心逻辑是:

  • 总任务数固定(如 urls.length);
  • 已发起的任务数 = 总数 − pendingCount(因为所有未 pending 的任务,要么正在运行,要么已结束);
  • 因此,剩余待发起请求数 = pendingCount
  • 进度百分比可近似为 (已完成数 / 总数) × 100 ≈ ((总数 − pendingCount) / 总数) × 100。

以下是一个生产就绪的示例,支持终端实时刷新进度条(兼容 Node.js 环境):

Aha
Aha

全天候网红营销AI智能体平台

下载
import pLimit from 'p-limit';

const urls = [
  'https://www.google.com/search?q=1',
  'https://www.google.com/search?q=2',
  'https://www.google.com/search?q=3',
  'https://www.google.com/search?q=4',
  'https://www.google.com/search?q=5',
  'https://www.google.com/search?q=6',
  'https://www.google.com/search?q=7',
  'https://www.google.com/search?q=8',
];

const limit = pLimit(3);
const promises: Promise[] = [];

for (const url of urls) {
  // 注意:此处不立即执行 fetch,而是交由 limit 调度
  promises.push(limit(() => fetch(url)));
}

// 启动进度监控(每秒更新一次)
const progressInterval = setInterval(() => {
  const remaining = limit.pendingCount; // ✅ 关键:当前排队等待执行的任务数
  const completed = urls.length - remaining - limit.running;
  const progress = Math.round(((completed / urls.length) * 100));

  // 终端覆盖式输出(保持单行刷新)
  process.stdout.clearLine(0);
  process.stdout.cursorTo(0);
  process.stdout.write(`✅ 进度: ${progress}% | 运行中: ${limit.running} | 排队中: ${remaining} | 总计: ${urls.length}`);
}, 1000);

try {
  const results = await Promise.allSettled(promises);

  // 清理定时器
  clearInterval(progressInterval);

  // 处理结果
  results.forEach((result, index) => {
    if (result.status === 'fulfilled') {
      console.log(`✓ ${urls[index]} → ${result.value.status}`);
    } else {
      console.error(`✗ ${urls[index]} → ${result.reason}`);
    }
  });

  console.log('\n? 所有请求已完成!');
} catch (error) {
  clearInterval(progressInterval);
  throw error;
}

⚠️ 重要注意事项

  • pendingCount 仅反映排队中、尚未被调度执行的任务数,不包括 running 中的任务。因此,“剩余请求数”严格等于 pendingCount,而非 pendingCount + running(后者是未完成总数)。
  • 定时器必须在 Promise.allSettled() 完成后显式清除(clearInterval),否则会持续运行造成内存泄漏。
  • process.stdout.clearLine() 和 cursorTo() 仅在 Node.js 的 TTY 环境(如终端)中有效;若需浏览器环境支持,应改用 DOM 更新(如 document.getElementById('progress').textContent = ...)。
  • 若任务创建与调度存在延迟(例如异步生成 URL),请确保 pendingCount 统计前所有任务均已注册到 limit(),否则初始值可能不准确。

总结:pendingCount 是 p-limit 提供的轻量级可观测性入口。结合 running 属性与总任务数,即可构建精准、低开销的并发任务仪表盘,无需引入复杂状态管理库,特别适合脚本化、运维类或 CLI 应用的用户体验增强。

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
length函数用法
length函数用法

length函数用于返回指定字符串的字符数或字节数。可以用于计算字符串的长度,以便在查询和处理字符串数据时进行操作和判断。 需要注意的是length函数计算的是字符串的字符数,而不是字节数。对于多字节字符集,一个字符可能由多个字节组成。因此,length函数在计算字符串长度时会将多字节字符作为一个字符来计算。更多关于length函数的用法,大家可以阅读本专题下面的文章。

939

2023.09.19

js正则表达式
js正则表达式

php中文网为大家提供各种js正则表达式语法大全以及各种js正则表达式使用的方法,还有更多js正则表达式的相关文章、相关下载、相关课程,供大家免费下载体验。

520

2023.06.20

js获取当前时间
js获取当前时间

JS全称JavaScript,是一种具有函数优先的轻量级,解释型或即时编译型的编程语言;它是一种属于网络的高级脚本语言,主要用于Web,常用来为网页添加各式各样的动态功能。js怎么获取当前时间呢?php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

350

2023.07.28

js 字符串转数组
js 字符串转数组

js字符串转数组的方法:1、使用“split()”方法;2、使用“Array.from()”方法;3、使用for循环遍历;4、使用“Array.split()”方法。本专题为大家提供js字符串转数组的相关的文章、下载、课程内容,供大家免费下载体验。

488

2023.08.03

js是什么意思
js是什么意思

JS是JavaScript的缩写,它是一种广泛应用于网页开发的脚本语言。JavaScript是一种解释性的、基于对象和事件驱动的编程语言,通常用于为网页增加交互性和动态性。它可以在网页上实现复杂的功能和效果,如表单验证、页面元素操作、动画效果、数据交互等。

5555

2023.08.17

js删除节点的方法
js删除节点的方法

js删除节点的方法有:1、removeChild()方法,用于从父节点中移除指定的子节点,它需要两个参数,第一个参数是要删除的子节点,第二个参数是父节点;2、parentNode.removeChild()方法,可以直接通过父节点调用来删除子节点;3、remove()方法,可以直接删除节点,而无需指定父节点;4、innerHTML属性,用于删除节点的内容。

487

2023.09.01

js截取字符串的方法
js截取字符串的方法

js截取字符串的方法有substring()方法、substr()方法、slice()方法、split()方法和slice()方法。本专题为大家提供字符串相关的文章、下载、课程内容,供大家免费下载体验。

214

2023.09.04

Js中concat和push的区别
Js中concat和push的区别

Js中concat和push的区别:1、concat用于将两个或多个数组合并成一个新数组,并返回这个新数组,而push用于向数组的末尾添加一个或多个元素,并返回修改后的数组的新长度;2、concat不会修改原始数组,是创建新的数组,而push会修改原数组,将新元素添加到原数组的末尾等等。本专题为大家提供concat和push相关的文章、下载、课程内容,供大家免费下载体验。

239

2023.09.14

2026春节习俗大全
2026春节习俗大全

本专题整合了2026春节习俗大全,阅读专题下面的文章了解更多详细内容。

68

2026.02.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号