Nodejs Async Promise Queue - PullRequest
Новая
       22

Nodejs Async Promise Queue

0 голосов
/ 24 мая 2018

Мне нужно использовать API с ограниченной скоростью.Например, я могу сделать только 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
    }

}

1 Ответ

0 голосов
/ 24 мая 2018

При текущей реализации api.get() будет вызываться немедленно , когда add отправляется в очередь.Вместо этого вы должны add путь (или, может быть, и api.get, и path), и AsyncQueue инициализировать Обещание, когда это возможно.Убедитесь, что add возвращает Promise, который разрешается после завершения вызова API.

Например, в vanilla 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');
});
...