Queue for parallel tasks that can cancel and is destoryable
Last updated 3 years ago by emilbayes .
ISC · Repository · Bugs · Original npm · Tarball · package.json
$ cnpm install parallel-queue 
SYNC missed versions from official npm registry.


Build Status

Queue for parallel tasks that can cancel and is destoryable


var parallelQueue = require('parallel-queue')

var pq = parallelQueue(4, function (args, done) {
  setTimeout(done, args.wait)

pq.push({wait: 30000})

// Cancel all pending tasks, and invoke callback on all running tasks with error


var queue = parallelQueue(parallel, worker)

Create a queue that is limited to parallel concurrent workers. worker will be invoked with (task, next), where task is whatever is pushed onto the queue and next is a normal callback function, passed an optional error as the first argument and up to three return values from succeeding arguments. These arguments will be passed on to the done callback in push.

var cancel = queue.push(task, done)

Queue task and call cb when done. queue.push will return a function that you can invoke to cancel the task, which in turn will invoke cb with a Error with err.cancel === true. If the task has already started, there is no way to cancel it, and it will not release a slot in the queue until done. If the queue has been destroyed, tasks will not be queued and done will be invoked immediately with an error.

Note: The task will not be executed before the nextTick as to avoid the worker function from plugging the event loop. This means you can .push and cancel as many tasks as you want synchronously, also from within the callback.

Note 2: You can cancel a running task, but that does not mean the actual work done by the worker is stopped, just that the cb supplied to .push is removed from the queue and called with an Error. The slot in the queue will be released as soon as the running worker calls the supplied next callback.


Cancel all pending tasks, and call the callback of all running tasks with an error. If err is not given, the default error will be used (see above).


Number of tasks that can run in parallel. This is read-only


Number of tasks pending in the queue. This is excluding the current task if accessed from within the worker function


Number of tasks running in the queue. This is including the current task if accessed from within the worker function.


Boolean set after destroy has finished


npm install parallel-queue



Current Tags

  • 3.0.1                                ...           latest (3 years ago)

5 Versions

  • 3.0.1                                ...           3 years ago
  • 2.0.1                                ...           3 years ago
  • 2.0.0                                ...           3 years ago
  • 1.0.0                                ...           3 years ago
  • 0.0.0                                ...           3 years ago
Maintainers (1)
Today 0
This Week 0
This Month 0
Last Day 0
Last Week 0
Last Month 2
Dependencies (0)
Dev Dependencies (3)
Dependents (0)

Copyright 2014 - 2016 © |