Function limitConcurrency

box/chavy.boxjs.js:1067–1090

(tasks, limit)

// 自定义并发控制函数
async function limitConcurrency(tasks, limit) {
  const results = [];
  const executing = [];

  for (const task of tasks) {
    const promise = task(); // 执行任务
    results.push(promise);

    if (executing.length >= limit) {
      await Promise.race(executing);
    }

    executing.push(promise);
    promise.then(() => {
      const index = executing.indexOf(promise);
      if (index !== -1) executing.splice(index, 1);
    }).catch(() => {
      const index = executing.indexOf(promise);
      if (index !== -1) executing.splice(index, 1);
    });
  }

  return Promise.all(results);
}

async function reloadAppSubCaches() {
  $.msg($.name, '更新订阅: 开始!');