Function limitConcurrency

chavy.box.js:1067–1092

(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, '更新订阅: 开始!')