worker pattern nodejs

worker.mjs

const CONCURRENCY = 5;
function sleep(ms) {
    return new Promise(resolve => setTimeout(resolve, ms));
}

const doWork = async (work) => {
    const duration = Math.random() > 0.5 ? 1000 : 10000
    await sleep(duration)
    return console.log("doing work", work)
}

const main = async () => {
    const work = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
    const workers = []
    for (let i = 0; i < CONCURRENCY; i++) {
        workers.push((async () => {
            while (work.length > 0) {
                const job = work.pop()
                console.log("Starting", job)
                await doWork(job)
            }
        })())
    }
    return Promise.all(workers)
}

main()