Promise.all 内存消耗:综合解决方案
在这种情况下,问题是由大量(58k)的 Promise 引起的准备解决。当每个 Promise 等待其实现时,相关的异步函数和结果数据会累积,最终导致内存消耗过多。
高效的 Promise 管理
要优化内存使用,请避免同时在内存中保存大量的 Promise 及其数据。相反,将并发操作(promise)的数量限制为合理的值(称为“X”)。例如,如果速率限制器允许每秒 20 个请求,则将 X 设置为 5 或 10 可能是一个合适的折衷方案。
实现并发控制
有多种方法执行并发控制:
1.带有并发选项的 Promise.map():
Bluebird 的 Promise.map() 提供了一个并发选项,允许指定最大并发操作数。这简化了管理并发的过程。
2.手动 Promise 管理:
或者,您可以实现自定义代码来管理并发。下面的示例演示了这种方法:
function mapConcurrent(items, maxConcurrent, fn) { // Limit concurrent operations to `maxConcurrent` let inFlightCntr = 0; return new Promise((resolve, reject) => { function runNext() { let i = index; let prom = fn(items[index], index++).then(...); inFlightCntr++; prom.finally(() => { inFlightCntr--; }); prom.then(...); // Run resolve/reject based on returned promise } function run() { // Process items while count is below the limit while (inFlightCntr < maxConcurrent && index < items.length) { runNext(); } // Resolve or reject parent promise based on completion } run(); }); }
3.占位符替换:
如果不需要解析的数据,可以通过用简单的占位符替换来加速其垃圾回收,例如数字:
const p = backgroundScheduler.getClanProfile(clanTags[i], true).then(data => { return 0; // Replace resolved value to promote garbage collection }); promiseArray.push(p);
以上是使用带有大量 Promise 的 Promise.all 时如何有效管理内存消耗?的详细内容。更多信息请关注PHP中文网其他相关文章!