3-livelock.js

'use strict';

const threads = require('node:worker_threads');
const { Worker, isMainThread } = threads;

const LOCKED = 0;
const UNLOCKED = 1;

class Mutex {
  constructor(shared, offset = 0, initial = false) {
    this.lock = new Int32Array(shared, offset, 1);
    if (initial) Atomics.store(this.lock, 0, UNLOCKED);
    this.owner = false;
  }

  enter(callback) {
    console.log(`Wait in worker${threads.threadId}`);
    Atomics.wait(this.lock, 0, LOCKED);
    console.log(`endWait in worker${threads.threadId}`);
    Atomics.store(this.lock, 0, LOCKED);
    this.owner = true;
    setTimeout(callback, 0);
  }

  leave() {
    if (!this.owner) return;
    Atomics.store(this.lock, 0, UNLOCKED);
    Atomics.notify(this.lock, 0, 1);
    this.owner = false;
  }
}

// Usage

if (isMainThread) {
  const buffer = new SharedArrayBuffer(8);
  const mutex1 = new Mutex(buffer, 0, true);
  const mutex2 = new Mutex(buffer, 4, true);
  console.dir({ mutex1, mutex2 });
  new Worker(__filename, { workerData: buffer });
  new Worker(__filename, { workerData: buffer });
} else {
  const { threadId, workerData } = threads;
  const mutex1 = new Mutex(workerData);
  const mutex2 = new Mutex(workerData, 4);

  const loop = () => {
    mutex1.enter(() => {
      console.log(`Entered mutex1 from worker${threadId}`);
      if (mutex1.leave()) console.log(`Left mutex1 from worker${threadId}`);
    });
    mutex2.enter(() => {
      console.log(`Entered mutex2 from worker${threadId}`);
      if (mutex2.leave()) console.log(`Left mutex2 from worker${threadId}`);
    });
    setTimeout(loop, 0);
  };
  loop();

}