【Node.js】 並列処理をおこなう三つのモジュールの概要

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

    // ①ワーカーの作成
const worker = new Worker( "./sub_worker.js",{workerData:{dataId:2}});

    // ②ワーカーからの受信設定
worker.on("message", msg => {
    console.log(`受信：${ msg }`); // 受信：返信:buff1=102 , buff2=202
});

const u8_1 = new Uint8Array( [100,101,102,103,104] );
const u8_2 = new Uint8Array( [200,201,202,203,204] );

    // ③ワーカーへのメッセージ送信
worker.postMessage({buff1:u8_1,buff2:u8_2},[u8_1.buffer]);
console.log( u8_1.length , u8_2.length); // 0 , 5

    // ④ワーカーを終了させる
setTimeout(()=>worker.terminate(),5000);

const {parentPort,workerData} = require("worker_threads");

const dataId = workerData.dataId;

parentPort.on("message", msg => {
    parentPort.postMessage(`返信:buff1=${ msg.buff1[dataId]} , buff2=${ msg.buff2[dataId]}`);
});

const child_process = require("child_process");

    // ①子プロセスの作成
const child1 = child_process.fork( "./child", ["こんにちは"] , {env:{id:1}});
const child2 = child_process.fork( "./child", ["こんばんは"] , {env:{id:2}});

   // ②子プロセスからのメッセージ受け取り設定
[child1,child2].forEach(e=>{
    e.on("message", msg => console.log(msg));
});
   // ③2秒後に子プロセスにメッセージ送信
setTimeout( ()=>{
    [child1,child2].forEach(e=>e.send({time:Date.now()}));
},2000);
   // ④5秒後に子プロセス停止
setTimeout( ()=>{
    [child1,child2].forEach(e=>e.disconnect());
},5000);

const [appName,jsName,arg] = process.argv;
const id = process.env.id;

process.on("message",  msg => {
    process.send( `${jsName}:${arg}(${id}):${msg.time}`);
});

const  cluster = require("cluster");

if(cluster.isPrimary) { // 親プロセス判定

    const cpuNum = require('os').cpus().length; // CPUコアの数

       // ①子プロセスの起動 ②メッセージの受信設定
    for (let i = 0; i < cpuNum; i++) {
        cluster.fork({ msg: `ID${i}` })
           .on("message", msg => console.log(msg));
    }

       // 5秒後に子プロセスを停止
    setTimeout( ()=>{
        cluster.disconnect();
    },5000);

}else{ // 子プロセスでの処理
    const msg = process.env.msg;
        // ③親スプセスにメッセージを送信
    process.send( `ワーカーからのメッセージ(${msg})` );
}

}else{ // 子プロセスでの処理
    require("http").createServer((req, res) => {
        res.writeHead(200,{'Content-Type': 'text/html; charset=utf-8'});
        res.end(`<p>${msg}</p>`);
       process.send( msg );
    }).listen(44001);

    const msg = `リクエスト受付(${process.env.msg})`;
}