q-semaphore

1.0.3 • Public • Published

q-semaphore

NPM Version NPM Downloads Build Status Coverage Status Dependency Status devDependency Status

Semaphore implementation for Q promises on Node.js

Install: npm install q-semaphore

Limit simultaneous access to a resource.

// Create
var sem = require('q-semaphore')(capacity);
 
// Take
sem.take([n=1]) // returns a promise
 
// Leave
sem.leave([n=1])
// Limit concurrent db access
var sem = require('semaphore')(1);
var server = require('http').createServer(req, res) {
    sem.take().then(function() {
        expensive_database_operation(function(err, res) {
            sem.leave();
 
            if (err) return res.end("Error");
 
            return res.end(res);
        });
    });
});
// 2 clients at a time
var sem = require('semaphore')(2);
var server = require('http').createServer(req, res) {
    res.write("Then good day, madam!");
 
    sem.take().then(function() {
        res.end("We hope to see you soon for tea.");
        sem.leave();
    });
});
// Rate limit
var sem = require('semaphore')(10);
var server = require('http').createServer(req, res) {
    sem.take().then(function() {
        res.end(".");
        
        return Q.delay(500);
    }).then(sem.leave);
});

License

MIT

This is based on the abrkn/semaphore.js implementation.

Readme

Keywords

none

Package Sidebar

Install

npm i q-semaphore

Weekly Downloads

0

Version

1.0.3

License

none

Last publish

Collaborators

  • addaleax