1.0.0 • Published 2 years ago
@esfx/threading-mutex v1.0.0
@esfx/threading-mutex
A Mutex
class that performs locking across Worker
instances using a SharedArrayBuffer
.
Overview
Installation
npm i @esfx/threading-mutex
Usage
import { Worker, isMainThread, parentPort, workerData } from "worker_threads";
import { Mutex } from "@esfx/threading-mutex";
import { StructType, int32 } from "@esfx/struct-type";
import { sleep } from "@esfx/threading-sleep";
const SharedData = StructType([
{ name: "x", type: int32 },
{ name: "y", type: int32 },
]);
function worker_thread() {
const m = new Mutex(workerData[0]);
const data = new SharedData(workerData[1]);
while (true) {
sleep(250);
m.lock();
try {
// inside of the lock we can mutate 'data' without
// main() seeing a partial update.
data.x++;
data.y--;
}
finally {
m.unlock();
}
}
}
function main() {
const m = new Mutex();
const data = new SharedData(/*shared*/ true);
const worker = new Worker(__filename, { workerData: [m.buffer, data.buffer] });
while (true) {
sleep(500);
m.lock();
try {
// inside of the lock, we know that we can safely read
// both 'x' and 'y' and the worker will not modify
// either value until we unlock.
console.log(`x: ${data.x}, y: ${data.y}`);
}
finally {
m.unlock();
}
}
}
if (isMainThread) {
main();
}
else {
worker_thread();
}
API
You can read more about the API here.
1.1.0-alpha.202307260322
2 years ago
1.1.0-alpha.202302091715
2 years ago
1.1.0-alpha.202306061406
2 years ago
1.1.0-alpha.202306061316
2 years ago
1.1.0-alpha.202306051228
2 years ago
1.1.0-alpha.202306080253
2 years ago
1.1.0-alpha.202302071935
2 years ago
1.1.0-alpha.202305082104
2 years ago
1.1.0-alpha.202211221509
3 years ago
1.1.0-alpha.202210252139
3 years ago
1.0.0
3 years ago
1.0.0-dev.7
3 years ago
1.0.0-pre.42
3 years ago
1.0.0-dev.8
3 years ago
1.0.0-pre.41
3 years ago
1.0.0-dev.5
3 years ago
1.0.0-pre.44
3 years ago
1.0.0-dev.6
3 years ago
1.0.0-pre.43
3 years ago
1.0.0-dev.4
3 years ago
1.0.0-prenative.0
3 years ago
1.0.0-prenative.1
3 years ago
1.0.0-dev.0
3 years ago
1.0.0-pre.40
3 years ago
1.0.0-pre.31
3 years ago
1.0.0-pre.33
3 years ago
1.0.0-pre.35
3 years ago
1.0.0-pre.34
3 years ago
1.0.0-pre.37
3 years ago
1.0.0-pre.36
3 years ago
1.0.0-pre.39
3 years ago
1.0.0-pre.38
3 years ago
1.1.0-alpha.202211291446
3 years ago
1.0.0-pre.30
4 years ago
1.0.0-pre.26
4 years ago
1.0.0-pre.25
4 years ago
1.0.0-pre.28
4 years ago
1.0.0-pre.29
4 years ago
1.0.0-pre.23
4 years ago
1.0.0-pre.20
4 years ago
1.0.0-pre.19
4 years ago
1.0.0-pre.17
4 years ago
1.0.0-pre.16
5 years ago
1.0.0-pre.13
6 years ago
1.0.0-pre.12
6 years ago
1.0.0-pre.11
6 years ago
1.0.0-pre.9
6 years ago
1.0.0-pre.8
6 years ago