【JSリファレンス】Atomicsオブジェクト

const {Worker} = require("worker_threads");

const buffer = new SharedArrayBuffer(
    Int32Array.BYTES_PER_ELEMENT*2);
new Worker("worker.js", { workerData:buffer });

const i32Array = new Int32Array(buffer);

setTimeout(()=>{
      // Workerに合図を送る
    Atomics.notify(i32Array, 1, 1);
    for(let i = 0;i < 500 ;i++){
        const before = Atomics.add( i32Array , 0 , 3 );
        const after = Atomics.load(i32Array,0);
        console.log( `main:${before} => ${after}` );
    }
},1000);

const {workerData:buffer} = require("worker_threads");

const i32Array = new Int32Array(buffer);

  // メインの開始合図まで停止する
Atomics.wait(i32Array,1,0);

for(let i = 0;i < 500 ;i++){
    const before = Atomics.add( i32Array , 0 , 3 );
    const after = Atomics.load(i32Array,0);
    console.log( `worker:${before} => ${after}` );
}