|
Server : Apache System : Linux cloud.heroica.com.br 4.18.0-553.36.1.el8_10.x86_64 #1 SMP Wed Jan 22 03:07:54 EST 2025 x86_64 User : farolpborg ( 1053) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /var/www/node_services/apimetaexamepopular/node_modules/thingies/lib/ |
Upload File : |
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.mutex = void 0;
const tslib_1 = require("tslib");
const codeMutex_1 = require("./codeMutex");
/**
* Executes only one instance of give code at a time. For parallel calls, it
* returns the result of the ongoing execution.
*/
function mutex(fn, context) {
const isDecorator = !!context;
if (!isDecorator) {
const mut = (0, codeMutex_1.codeMutex)();
return function (...args) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
return yield mut(() => tslib_1.__awaiter(this, void 0, void 0, function* () { return yield fn.call(this, ...args); }));
});
};
}
const instances = new WeakMap();
return function (...args) {
return tslib_1.__awaiter(this, void 0, void 0, function* () {
let map = instances.get(this);
if (!map)
instances.set(this, (map = new WeakMap()));
if (!map.has(fn))
map.set(fn, (0, codeMutex_1.codeMutex)());
return yield map.get(fn)(() => tslib_1.__awaiter(this, void 0, void 0, function* () { return yield fn.call(this, ...args); }));
});
};
}
exports.mutex = mutex;