示例说明
通过固定并发池运行异步任务，带背压收集有序结果，同时将未完成 Promise 限制在有界数量内。本示例属于数据获取场景，提供可直接复制使用的javascript代码片段，附带边界条件与使用注意事项。
技术要点
- nextIndex 共享游标 worker 自取任务
- results 按原始索引保证顺序
- concurrency 上限控制 outstanding Promise
代码解读
上述代码实现了带背压的 Promise 并发池映射的核心逻辑。通过固定并发池运行异步任务，带背压收集有序结果，同时将未完成 Promise 限制在有界数量内。代码中包含输入校验、核心算法和结果返回三个部分。关键在于正确处理边界情况，例如空输入、非法参数和并发场景。nextIndex 共享游标 worker 自取任务，results 按原始索引保证顺序。这些设计确保代码在生产环境中的健壮性。
使用建议
在实际项目中使用本示例时，建议先理解带背压的 Promise 并发池映射的适用场景与限制条件。concurrency 上限控制 outstanding Promise。根据具体业务需求调整参数配置，并编写单元测试覆盖正常路径与边界情况。本代码片段可直接集成到现有项目中，或作为参考实现自行扩展。
代码示例
export async function promisePool(items,worker,concurrency=4){const results=new Array(items.length);let next=0;async function run(){while(true){const i=next++;if(i>=items.length)return;results[i]=await worker(items[i],i);}}const runners=Array.from({length:Math.min(concurrency,items.length)},()=>run());await Promise.all(runners);return results;}