Simple worker pool in javascript/nodejs

index.js

function createWorkerPool(max) {
    let current = 0
    let queue = []

    async function run() {
        if(current >= max || queue.length === 0) return

        current++
        let action = queue.shift()
        
        new Promise(async resolve => {
            await action()
            current--
            run()
        })
    }

    return ({
        add: (action) => {
            queue.push(action)
            run()
        }
    })
}


//Usage exemple ::::

const worker = createWorkerPool(2)

worker.add(async function() {
    //terceira execução
    await new Promise(resolve => setTimeout(() => resolve(), 2000))
    console.log("Primeira ação")
})

worker.add(async function() {
    //primeira execução porque executa 1 segundo mais rápido
    await new Promise(resolve => setTimeout(() => resolve(), 1000))
    console.log("Segunda ação")
})

worker.add(function() {
    //segunda execução porque executa depois da primeira que libeira uma posição no workerpool
    console.log("Terceira ação")
})