workq

    3.0.0 • Public • Published

    workq

    js-standard-style Build Status Coverage Status

    A super tiny work queue.

    It can handle nested queues, the order of execution is guaranteed.
    The top level queue will start automatically once you add at least one job in the queue, the nested queues will start once the done callback has been called; you cannot add more jobs in the current queue after done has been called.

    If you need a shared queue between multiple files pass the option { singleton: true } in every file you need it.

    Install

    npm i workq --save
    

    Usage

    const q = require('workq')()
     
    q.add(job)
     
    function job (child, done) {
      // perform some work
      // you can add nested jobs!
      child.add(nestedJob)
      done()
    })
     
    function nestedJob (child, done) {
      // perform some work
      done()
    })

    Async/await and promises are supported as well!

    const q = require('workq')()
     
    q.add(job)
     
    // there is no need to call `done`!
    async function job (child) {
      // perform some work
      // you can add nested jobs!
      child.add(nestedJob)
    })
     
    async function nestedJob (child) {
      // perform some work
    })

    If you need to know when a queue has finished all its jobs, you can use the drain api.
    Note that in the top queue the drain hook can be called multiple times.

    const q = require('workq')()
     
    q.drain(done => {
      // the current queue has finished its jobs
      // async await is supported as well
      done()
    })
     
    q.add(job)
     
    function job (child, done) {
      // perform some work
      // you can add nested jobs!
      child.add(nestedJob)
      done()
    })
     
    function nestedJob (child, done) {
      // perform some work
      done()
    })

    If you need to pass some parameter to the job, just add them after the function in add:

    const q = require('workq')()
     
    q.add(job, 'hello', 42)
     
    function job (child, greeting, num, done) {
      console.log(greeting, num) // 'hello' 42
      done()
    })

    If needed you can also use the child method to create custom child queues. The child queues will be executed once the current queue has finished its execution.

    const q = require('workq')()
     
    const childq = q.child()
     
    q.add(job, 'hello', 42)
    childq.add(job, 'hello', 42)
     
    function job (child, greeting, num, done) {
      console.log(greeting, num) // 'hello' 42
      done()
    })

    License

    Licensed under MIT.

    Install

    npm i workq

    DownloadsWeekly Downloads

    1,867

    Version

    3.0.0

    License

    MIT

    Unpacked Size

    26.3 kB

    Total Files

    9

    Last publish

    Collaborators

    • delvedor