promise-queue-timeout

![Build][gh-image]
[![version][version-image]][npm-url]
[![semantic-release][semantic-image]][semantic-url]
[![License][license-image]][license-url]

promise queue with option to limit new task start time with timeout

Install

- yarn:

``bash
yarn add @shelex/promise-queue-timeout
`

- npm:

`bash
npm install @shelex/promise-queue-timeout
`

Usage

`js
import Queue from '@shelex/promise-queue-timeout';
// const Queue = require("@shelex/promise-queue-timeout")

const runner = new Queue({
executors: 2,
timeout: 2000 // ms
});

runner.enqueue(task, 'A'); // starts automatically
runner.enqueue(task, 'B'); // will be started after 2000ms
runner.enqueue(task, 'C'); // will be started when A or B finished, but after 2000ms from previous start

runner.on('resolve', (data) => console.log(data));
runner.on('reject', (error) => console.error(error));

runner.on('end', () =>
console.log(queue finished, all enqueued tasks processed)
);
`

API

$3

Constructor. options may contain inital values for:

- q.executors, default: 2; number of tasks executed
- q.timeout`, default: 1000; number of ms after previous task start time

$3

Add a task to queue which immediately starts processing.
Task is a function that returns a promise. Id is optional.

$3

Stops the queue and clears tasks backlog. can be resumed with enqueuing new taks.

$3

Returns resolved value for next executed task

$3

queue started tasks processing

$3

queue processed all tasks

$3

queue stopped processing current tasks and cleared backlog

$3

queue starting task. Callback has task ID and remaining counter for tasks backlog

$3

returns value resolved for just executed task

$3

returns err for rejected promise for just executed task

$3

queue is selecting next task from backlog

Motivation

This queue is an attempt to solve issue with parallelizing testing engines which are fighting for shared resources on initialization, so adding a timeout after start would allow to limit such concurrent startup.

License

Copyright © 2020 Oleksandr Shevtsov

This work is free. You can redistribute it and/or modify it under the
terms of the MIT License.
See LICENSE for full details.

[npm-url]: https://npmjs.com/package/@shelex/promise-queue-timeout
[gh-image]: https://github.com/Shelex/promise-queue-timeout/workflows/Release/badge.svg?branch=master
[types-path]: ./index.d.ts
[semantic-image]: https://img.shields.io/badge/%20%20%F0%9F%93%A6%F0%9F%9A%80-semantic--release-e10079.svg
[semantic-url]: https://github.com/semantic-release/semantic-release
[license-image]: https://img.shields.io/npm/l/@shelex/promise-queue-timeout
[license-url]: https://opensource.org/licenses/MIT
[version-image]: https://badgen.net/npm/v/@shelex/promise-queue-timeout/latest