44 lines
1.6 KiB
JavaScript
44 lines
1.6 KiB
JavaScript
|
"use strict";
|
||
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||
|
|
var tslib_1 = require("tslib");
|
||
|
|
var Semaphore_1 = require("./Semaphore");
|
||
|
|
var Mutex = /** @class */ (function () {
|
||
|
|
function Mutex(cancelError) {
|
||
|
|
this._semaphore = new Semaphore_1.default(1, cancelError);
|
||
|
|
}
|
||
|
|
Mutex.prototype.acquire = function () {
|
||
|
|
return tslib_1.__awaiter(this, arguments, void 0, function (priority) {
|
||
|
|
var _a, releaser;
|
||
|
|
if (priority === void 0) { priority = 0; }
|
||
|
|
return tslib_1.__generator(this, function (_b) {
|
||
|
|
switch (_b.label) {
|
||
|
|
case 0: return [4 /*yield*/, this._semaphore.acquire(1, priority)];
|
||
|
|
case 1:
|
||
|
|
_a = _b.sent(), releaser = _a[1];
|
||
|
|
return [2 /*return*/, releaser];
|
||
|
|
}
|
||
|
|
});
|
||
|
|
});
|
||
|
|
};
|
||
|
|
Mutex.prototype.runExclusive = function (callback, priority) {
|
||
|
|
if (priority === void 0) { priority = 0; }
|
||
|
|
return this._semaphore.runExclusive(function () { return callback(); }, 1, priority);
|
||
|
|
};
|
||
|
|
Mutex.prototype.isLocked = function () {
|
||
|
|
return this._semaphore.isLocked();
|
||
|
|
};
|
||
|
|
Mutex.prototype.waitForUnlock = function (priority) {
|
||
|
|
if (priority === void 0) { priority = 0; }
|
||
|
|
return this._semaphore.waitForUnlock(1, priority);
|
||
|
|
};
|
||
|
|
Mutex.prototype.release = function () {
|
||
|
|
if (this._semaphore.isLocked())
|
||
|
|
this._semaphore.release();
|
||
|
|
};
|
||
|
|
Mutex.prototype.cancel = function () {
|
||
|
|
return this._semaphore.cancel();
|
||
|
|
};
|
||
|
|
return Mutex;
|
||
|
|
}());
|
||
|
|
exports.default = Mutex;
|