// 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"));