19 lines
423 B
JavaScript
19 lines
423 B
JavaScript
|
const { Worker } = require("worker_threads");
|
||
|
|
let nb = 0;
|
||
|
|
|
||
|
|
|
||
|
|
function startWorker(workerArgs) {
|
||
|
|
let worker = new Worker(...workerArgs);
|
||
|
|
worker.on("error", (err) => {
|
||
|
|
console.error(err);
|
||
|
|
nb--;
|
||
|
|
if (nb > 0)
|
||
|
|
startWorker(workerArgs);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
module.exports = (app) => {
|
||
|
|
const workerArgs = ["./agenda/worker.js", {workerData: app.get("config")}];
|
||
|
|
startWorker(workerArgs);
|
||
|
|
};
|