AsyncQueue

AsyncQueue

new AsyncQueue();

Properties

public entries: any

The queued entries

• Source

public exceptionHandler: any

• Source

public size: any

The total number of entries in this queue. Returns 0 if no entries are available.

• Source

Methods

public acquire(options?): AsyncQueueEntry

Acquire an entry.

// lock the queue
const entry = asyncQueue.acquire();
// wait until previous task is completed
await entry.getTask();
// do something expensive
await performSomethingExpensive();
// make sure to release the lock once done
asyncQueue.release();

• Source

public cancelAll(): void

Cancel all entries

• Source

public clear(consume): void

Clear entries queue

• Source

public release(): void

Release the current acquisition and move to next entry.

• Source

public removeEntry(entry): boolean

Remove the given entry from the queue

• Source