How to implement a pseudo blocking async queue in JS/TS?

by

It’s quite simple actually, dequeue will create a promise that enqueue will resolve. We just have to keep the resolvers in a queue – and also care about the case where values are enqueued before they are dequeued, keeping the already fulfilled promises in a queue.

class AsyncBlockingQueue {
  constructor() {
    // invariant: at least one of the arrays is empty
    this.resolvers = [];
    this.promises = [];
  }
  _add() {
    this.promises.push(new Promise(resolve => {
      this.resolvers.push(resolve);
    }));
  }
  enqueue(t) {
    // if (this.resolvers.length) this.resolvers.shift()(t);
    // else this.promises.push(Promise.resolve(t));
    if (!this.resolvers.length) this._add();
    this.resolvers.shift()(t);
  }
  dequeue() {
    if (!this.promises.length) this._add();
    return this.promises.shift();
  }
  // now some utilities:
  isEmpty() { // there are no values available
    return !this.promises.length; // this.length <= 0
  }
  isBlocked() { // it's waiting for values
    return !!this.resolvers.length; // this.length < 0
  }
  get length() {
    return this.promises.length - this.resolvers.length;
  }
  [Symbol.asyncIterator]() {
    // Todo: Use AsyncIterator.from()
    return {
      next: () => this.dequeue().then(value => ({done: false, value})),
      [Symbol.asyncIterator]() { return this; },
    };
  }
}

I don’t know TypeScript, but presumably it’s simple to add the the necessary type annotations.

For better performance, use a Queue implementation with circular buffers instead of plain arrays, e.g. this one. You might also use only a single queue and remember whether you currently store promises or resolvers.

More Related Contents:

  1. Use async await with Array.map
  2. async/await always returns promise
  3. How to turn this callback into a promise using async/await?
  4. What is the difference between JavaScript promises and async await?
  5. How to wait for a JavaScript Promise to resolve before resuming function?
  6. How to async await in react render function?
  7. using async await and .then together
  8. What are asynchronous functions in JavaScript? What is “async” and “await” in JavaScript?
  9. How do I return the response from an Observable/http/async call in angular?
  10. Correct Try…Catch Syntax Using Async/Await
  11. Syntax for an async arrow function
  12. Limited parallelism with async/await in Typescript/ES7
  13. $.Deferred: How to detect when every promise has been executed
  14. What does $.when.apply($, someArray) do?
  15. Can’t throw error from within an async promise executor function
  16. for await of VS Promise.all
  17. JavaScript array .reduce with async/await
  18. Throttle amount of promises open at a given time
  19. How to return an Ajax result using async/await? [duplicate]
  20. Do Javascript promises block the stack
  21. Javascript – if with asynchronous case
  22. Using mongoose promises with async/await
  23. typescript: error TS2693: ‘Promise’ only refers to a type, but is being used as a value here
  24. How does javascript async/await actually work?
  25. How to use Promise.all with an object as input
  26. Why are javascript promises asynchronous when calling only synchronous functions?
  27. Using “await” inside non-async function
  28. How can I Interleave / merge async iterables?
  29. Implement async/await in sort function of arrays javascript
  30. JS async/await – why does await need async?

Leave a Comment