@mapbox/locking :lock:

npm install --save @mapbox/locking

Wrap any callback or async function to use an LRU cache and prevent (lock) asynchronous operations across concurrent calls.

Usage

const { Locking, LockingAsync } = require('@mapbox/locking');

The options objects are passed directly to lru-cache allowing you to set the max age, max items, and other behaviors of the LRU cache. When options.allowStale is set to true the locking cache implements additional behavior to continue serving a stale item until the item has been refreshed in the background.

Locking(function, options)

For locking callback functions in the form function(id, callback). Returns a callable function

const { Locking } = require('@mapbox/locking');
const fs = require('fs');
const readFile = Locking(fs.readFile, options);

// Reads file once, calls callback 10x.
for (let i = 0; i < 10; i++) {
  readFile('./sample.txt', function(err, data) {
    console.log(data);
  });
}

LockingAsync(function, options)

Constructor for locking promise or async functions in the form of function(...arguments). This can manage functions of arbitrary arguments and types. Returns a class with two functions, which includes a callable method get() for calling the original function.

const { LockingAsync } = require('@mapbox/locking');
const got = require('got');

const jsonApi = new Locking((url) => {
  return got(url).json();
}, options);

// call function
await jsonApi.get('https://api.mapbox.com');
await jsonApi.get('https://api.mapbox.com');
await jsonApi.get('https://api.mapbox.com');

// get stats
console.log(jsonApi.stats); // { total: 3, hit: 2, miss: 1, locks: 2, refreshHit: 0, currentLocks: 0, size: 1 }