js 一个promise数组且该数组会随时添加新promise要怎么样一个一个同步执行？

Question

js 一个promise数组且该数组会随时添加新promise，要怎么样一个一个同步执行
有可能执行完一个promise过一会才会添加新的

Answer 1

原生不支持，自己控制 promise 就行了。

先写期待的用法：

// 主进程
const myPromiseAll = new MyPromiseAll([...启动时的异步操作]);
await myPromiseAll.promise;
// 继续其它操作

// 事件函数
function onClick() {
  myPromiseAll.add(新异步操作);
}

然后简单实现一下 MyPromiseAll 这个类：

class myPromiseAll(
  promise;

  #tasks = 0;
  #count = 0;
  #resolve;
  #reject;

  constructor(tasks) {
    for (const task of tasks) {
      this.add(task);
    }
    this.promise = new Promise((resolve, reject) => {
      this.#resolve = resolve;
        this.#reject = reject;
    });
  }
  add(task) {
    task.then(() => {
      this.#count++;
      if (this.#count >= this.#tasks) {
        this.#resolve();
      }
    }).catch(err => {
      // this.#reject();
    });
    this.#tasks++;
  }
}

没测，你自己根据需求改改吧。

Answer 2

粗略的设计,弄个定时器,定义个全局promise数组,然后再弄个循环定时器 setInterval 不断读取这个全局数组进行执行,理论上是没问题,但是细节需要打磨

Answer 3

来个骚操作,用异步迭代器做promise队列(建议看懂了再用,目前没法在每次next时拿到任务执行的promise,等function.sent提案)

const sleep = async (time) => {
  console.log('start task', time, Date.now());
  return new Promise((resolve) =>
    setTimeout(() => {
      console.log('resolve', time, Date.now());
      resolve(true);
    }, time),
  );
};

async function* promiseQueue() {
  while (1) await (yield)();
}
const pmsQueue = promiseQueue();
pmsQueue.next(() => Promise.resolve(true)); // 第一次会被忽略,等function.sent提案

console.log('start:', Date.now());
pmsQueue.next(() => sleep(3000));
pmsQueue.next(() => sleep(5000));
pmsQueue.next(() => sleep(8000));
/*
start: 1699617365646
start task 3000 1699617365646
resolve 3000 1699617368656
start task 5000 1699617368657
resolve 5000 1699617373666
start task 8000 1699617373667
resolve 8000 1699617381675
*/

Answer 4

要一个一个同步执行，用一个叫p-limit的工具最方便

import pLimit from 'p-limit'

// 一个一个执行，那就限制1个并发
const limit = pLimit(1)

limit(() => fetchSomething('foo'))
limit(() => fetchSomething('bar'))
limit(() => doSomething())

// 可能在几秒之后
limit(() => doSomethingSecondsLater())