@calebboyd/semaphore

Simple promise based counting semaphore

Downloads in past

Stats

StarsIssuesVersionUpdatedCreatedSize
@calebboyd/semaphore
1.3.14 years ago6 years agoMinified + gzip package size for @calebboyd/semaphore in KB

Readme

Semaphore

Naive resource management / concurrency primitive
npm i @calebboyd/semaphore

Example

import { Semaphore } from '@calebboyd/semaphore'
import { something } from './somewhere'

function doSomeWork () {
  const lock = new Semaphore(10)
  while(something.isTrue) {
    lock.acquire().then(x => () => {
      something.work().then(lock.release)
    })    
  }
}
The semaphore will only allow 10 locks to be aquired at a time. This limits the concurrency of the asyncronous function something.work to 10

API:

export class Semaphore {
  constructor (count: number) {}
  acquire(): Promise<void>
  release(): void
}

License

MIT