test/js/node/worker_threads/worker.js


1
2
3
4
5
6
7
8

const wt = require("worker_threads");

wt.parentPort.on("message", e => {
  let sharedBufferView = new Int32Array(e.sharedBuffer);
  wt.workerData.postMessage("done!");
  Atomics.add(sharedBufferView, 0, 1);
  Atomics.notify(sharedBufferView, 0, Infinity);
});