异步任务并发量
原题：请实现如下函数，可以并发请求数据，所有的 URL 地址在 urls 参数中，同时可以通过 max 参数控制请求的并发度，当所有请求结束之后，需要执行 callback 回调函数。
这里通过 sleep 模拟实现
async function sleep(n, name = "test") {
return new Promise((resolve) => {
console.log("start", name, n);
setTimeout(() => {
console.log("end", name, n);
resolve();
}, n);
});
}
// 限制并发数 items是异步函数队列
async function asyncPool({ max, items }) {
const results = [];
const pool = new Set();
for (const item of items) {
// 避免传入的不是 Promise
const fn = async (item) => await item();
const promise = fn(item);
results.push(promise);
pool.add(promise);
// 无论执行结果是成功还是失败都清除
const clean = () => pool.delete(promise);
promise.then(clean, clean);
if (pool.size >= max) {
// 等待最快的 Promise 执行完毕，才会执行下一次 for 循环
await Promise.race(pool);
}
}
return Promise.allSettled(results);
}
async function start() {
await asyncPool({
max: 2,
items: [
() => sleep(1000, "1000"),
() => sleep(4000, "4000"),
() => sleep(3500, "3500"),
() => sleep(5000, "5000"),
() => sleep(2000, "2000"),
],
});
console.log("all done");
}
start();
// 执行结果
// start 1000 1000
// start 4000 4000
// end 1000 1000
// start 3500 3500
// end 4000 4000
// start 5000 5000
// end 3500 3500
// start 2000 2000
// end 2000 2000
// end 5000 5000
// all done