worker_thread:node.js | Codetter（こーどったー）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
"use strict";
const {Worker,isMainThread,workerData,parentPort,threadId}=require("worker_threads");
const cores=4;
var maxsum=5000000000;
if(!isMainThread){
    maxsum=workerData.maxsum;
    var esum=0;
    for(var i=0;i<maxsum;i++){
        esum++;
    }
    parentPort.postMessage(esum);
    process.exit();
}
console.time();
maxsum/=cores;
var sum=0;
(async function(){
    const myWorkers=Array(cores).fill().map(n=>new Promise(resolve=>{
        new Worker(__filename,{workerData:{maxsum: maxsum}})
        .once("message",esum=>{
            sum=sum+esum;
            return resolve();
        });
    }));
    await Promise.all(myWorkers);
    console.log(sum);
    console.timeEnd();
})();
XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX