A work execution queue that provides gating. Work items submitted to the queue are called in order, and execute concurrently. However, if the queue is gated, then a sub-queue is created, and work items added to the sub-queue must complete first.
Gating operates to any depth, allowing you to form a tree-structured queue that must complete breadth-first.
The queue also handles timeouts, so that failing work items do not
block processing. Timeouts use a shared setInterval, so are nice and
efficient.
Used by the Seneca microservice framework to implement plugin initialisation.
var GateExecutor = require('gate-executor')
var ge = GateExecutor()
ge.add({
fn: function first (done) {
console.log('first')
done()
}
})
// create a gate
var subge = ge.gate()
ge.add({
fn: function second (done) {
console.log('second')
done()
}
})
// this needs to complete before 'second' can run
subge.add({
fn: function second (done) {
console.log('third')
done()
}
})
ge.start(function () {
console.log('done')
done()
})
// prints:
// first
// third
// second
// doneFor detailed information, and API descriptions, see the Annotated Source
If you're using this module, feel free to contact me on twitter if you have any questions! :) @rjrodger
npm test
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent