You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
78 lines
1.8 KiB
78 lines
1.8 KiB
import {KeyedMutex} from 'app/common/KeyedMutex';
|
|
import {delay} from 'bluebird';
|
|
import {assert} from 'chai';
|
|
|
|
describe('KeyedMutex', function() {
|
|
it('orders actions correctly', async function() {
|
|
const m = new KeyedMutex();
|
|
let v1: number = 0;
|
|
let v2: number = 0;
|
|
|
|
const fastAdd2 = m.acquire('2').then(unlock => {
|
|
v2++;
|
|
unlock();
|
|
});
|
|
const slowDouble2 = m.acquire('2').then(async unlock => {
|
|
await delay(1000);
|
|
v2 *= 2;
|
|
unlock();
|
|
});
|
|
assert.equal(m.size, 1);
|
|
|
|
const slowAdd1 = m.acquire('1').then(async unlock => {
|
|
await delay(500);
|
|
v1++;
|
|
unlock();
|
|
});
|
|
const immediateDouble1 = m.acquire('1').then(unlock => {
|
|
v1 *= 2;
|
|
unlock();
|
|
});
|
|
assert.equal(m.size, 2);
|
|
|
|
await Promise.all([slowAdd1, immediateDouble1]);
|
|
assert.equal(m.size, 1);
|
|
assert.equal(v1, 2);
|
|
assert.equal(v2, 1);
|
|
|
|
await Promise.all([fastAdd2, slowDouble2]);
|
|
assert.equal(m.size, 0);
|
|
assert.equal(v1, 2);
|
|
assert.equal(v2, 2);
|
|
});
|
|
|
|
it('runs operations exclusively', async function() {
|
|
const m = new KeyedMutex();
|
|
let v1: number = 0;
|
|
let v2: number = 0;
|
|
|
|
const fastAdd2 = m.runExclusive('2', async () => {
|
|
v2++;
|
|
});
|
|
const slowDouble2 = m.runExclusive('2', async () => {
|
|
await delay(1000);
|
|
v2 *= 2;
|
|
});
|
|
assert.equal(m.size, 1);
|
|
|
|
const slowAdd1 = m.runExclusive('1', async () => {
|
|
await delay(500);
|
|
v1++;
|
|
});
|
|
const immediateDouble1 = m.runExclusive('1', async () => {
|
|
v1 *= 2;
|
|
});
|
|
assert.equal(m.size, 2);
|
|
|
|
await Promise.all([slowAdd1, immediateDouble1]);
|
|
assert.equal(m.size, 1);
|
|
assert.equal(v1, 2);
|
|
assert.equal(v2, 1);
|
|
|
|
await Promise.all([fastAdd2, slowDouble2]);
|
|
assert.equal(m.size, 0);
|
|
assert.equal(v1, 2);
|
|
assert.equal(v2, 2);
|
|
});
|
|
});
|