sgauthier
6e64e138e2
All checks were successful
Publish To Prod / deploy_and_publish (push) Successful in 35s
45 lines
1.3 KiB
JavaScript
45 lines
1.3 KiB
JavaScript
"use strict";
|
|
|
|
Object.defineProperty(exports, "__esModule", {
|
|
value: true
|
|
});
|
|
exports.asyncLock = asyncLock;
|
|
var _semaphore = _interopRequireDefault(require("semaphore"));
|
|
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
|
function asyncLock() {
|
|
let lock = (0, _semaphore.default)(1);
|
|
function acquire(timeout = 15000) {
|
|
const promise = new Promise(resolve => {
|
|
// this makes sure a caller doesn't gets stuck forever awaiting on the lock
|
|
const timeoutId = setTimeout(() => {
|
|
// we reset the lock in that case to allow future consumers to use it without being blocked
|
|
lock = (0, _semaphore.default)(1);
|
|
resolve(false);
|
|
}, timeout);
|
|
lock.take(() => {
|
|
clearTimeout(timeoutId);
|
|
resolve(true);
|
|
});
|
|
});
|
|
return promise;
|
|
}
|
|
function release() {
|
|
try {
|
|
// suppress too many calls to leave error
|
|
lock.leave();
|
|
} catch (e) {
|
|
// calling 'leave' too many times might not be good behavior
|
|
// but there is no reason to completely fail on it
|
|
if (e.message !== 'leave called too many times.') {
|
|
throw e;
|
|
} else {
|
|
console.warn('leave called too many times.');
|
|
lock = (0, _semaphore.default)(1);
|
|
}
|
|
}
|
|
}
|
|
return {
|
|
acquire,
|
|
release
|
|
};
|
|
} |