four_index.js

const express = require('express')
const app = express();
const port = 4000;

const { Worker } = require('worker_threads')

const THREAD_COUNT = 4;


app.get('/non-blocking', (req, res) => {
    res.send("this is Non Blocking Response Sent");
})

function createWorker() {
    return new Promise((resolve, reject) => {
        const worker = new Worker('./four_worker.js', {
            workerData: { thread_count: THREAD_COUNT }
        })

        worker.on("message", (data) => {
            resolve(data)
        })
        worker.on("error", (err) => {
            reject(`an error ${err}`)
        })
    })
}

app.get('/blocking', async (req, res) => {
    const workerPromises = [];
    for (let i = 0; i < THREAD_COUNT; i++) {
        workerPromises.push(createWorker())
    }
    const thread_results = await Promise.all(workerPromises);
    const total = thread_results[0] +thread_results[1]+ thread_results[2] + thread_results[3];
    res.status(200).send(`counter result ${total}`);
})


app.listen(port, () => {
    console.log("server listening on port=> ", port);
})