import {Worker} from 'node:worker_threads'
import {cpus} from 'os'

cpus().forEach(() => {  // 2 cpus
    const worker = new Worker('./worker.mjs');
})

import Queue from 'bee-queue';
import {setTimeout} from 'timers/promises'

const queue = new Queue('queue', {
    redis: {
        host: '127.0.0.1',
        port: 6379
    },
    autoConnect: true, 
});

queue.process(async (job) => {
    console.log("start")
    await setTimeout(5000);
    console.log("end");
    return {done: "Done!"}
})

queue.createJob({}).save();