1.0.0 • Published 2 years ago

@esfx/threading-mutex v1.0.0

Weekly downloads
2
License
Apache-2.0
Repository
github
Last release
2 years ago

@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.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-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.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