// Main Thread
|
const { Worker } = require('worker_threads');
|
|
const until = 1000000;
|
const threads = 16;
|
const workers = [];
|
|
const range = Math.floor(until / threads);
|
|
console.time("primes");
|
|
for (let i = 0; i < threads; i++) {
|
const workerPromise = new Promise((r) => {
|
const worker = new Worker("./mt-worker", { workerData: {from: i * range, to: (i + 1) * range}});
|
|
worker.on("message", () => r());
|
})
|
|
workers.push(workerPromise);
|
}
|
|
Promise.all(workers).then(() => console.timeEnd("primes"));
|
