sema
v2.0.3
Published
Async semaphore for shared or exclusive execution.
Downloads
93
Readme
sema
Async semaphore for shared or exclusive execution of JavaScript functions.
npm install sema
var sema = require('sema')
var s = sema()
// exclusive mode
s.acquire(function () {
...
doReadWrite(function (err) {
...
s.release()
})
})
// shared mode
s.acquire(sema.SHARED, function () {
...
doReadOnly(function (err) {
...
s.release()
})
})
API
var s = sema()
Creates a semaphore instance.
s.acquire([mode], [fn])
Acquire semaphore. Defaults to exclusive mode. Setting mode sema.SHARED
to acquire a shared mode.
Callback to asynchronous function fn
when semaphore available.
Invoked immediately if semaphore is free or shared only. Otherwise pushed to the wait queue.
Returns a promise if no fn
provided. However this yields a slight delay when acquiring, due to the nature of promise. If such timing is important then callback function should be used.
s.release()
Release semaphore.
Invokes function from the wait queue if queue is not empty.
s.mode()
Returns mode constant, the current state of semaphore.
Mode Constants
sema.FREE = null
sema.SHARED = 1
sema.EXCLUSIVE = 2
sema.WAIT = 3
License
MIT