NodeJS异步承诺队列

我需要消费限价接口。例如，我一秒只能调用10个API，因此我需要等待当前秒结束后才能进行另一个API调用。

要实现这一点，我想创建一个可以自己管理这一点的异步队列。它的主要功能是让我向队列中添加一个新的承诺，当承诺被解析时，应用程序会收到通知：

let queue = new Queue()

queue.add(api.get('/somepath')).then(res => { // handle response });

如何使用普通承诺实现此目标？

export class AsyncQueue {

    private queue: Array<Promise<any>>;


    add(promise, fct) {
        this.queue.push(promise);
    }

    resolveNext() {
        this.queue.pop().then({
            // how to resolve the waiting promise in my application
        })
    }

    get length() {
        return this.queue.length
    }

}

---

解决方案

在当前实现中，api.get()在add进入队列时会被立即调用。您应该改为add路径(或者同时使用api.get和path)，并让AsyncQueue在可能时初始化承诺。确保让add返回一旦API调用完成即可解析的承诺。

例如，在Vanilla JS中，它可能如下所示：

数据-lang="js"数据-隐藏="假"数据-控制台="真"数据-巴贝尔="真">

const apiGet = () => new Promise(resolve => setTimeout(resolve, 1000));

class AsyncQueue {
  queue = [];
  constructor() {
    setInterval(this.resolveNext.bind(this), 2000);
  }
  add(fn, param) {
    return new Promise(resolve => {
      this.queue.unshift({ fn, param, resolve });
    });
  }
  resolveNext() {
    if (!this.queue.length) return;
    const { fn, param, resolve } = this.queue.pop();
    fn(param).then(resolve);
  }
}


const queue = new AsyncQueue()
console.log('start');
// Will resolve after 2000 + 1000 seconds:
queue.add(apiGet, '/somepath').then(res => {
  console.log('handling response 1');
});
// Will resolve after 4000 + 1000 seconds:
queue.add(apiGet, '/somepath').then(res => {
  console.log('handling response 2');
});