Estoy usando un subproceso de trabajo en el nodo js, a continuación se muestra mi código en dos archivos
worker.js
const mysql = require('mysql2'); const { v1: uuidv1, v4: uuidv4, } = require('uuid'); const {parentPort, workerData} = require("worker_threads"); const dayjs = require('dayjs'); parentPort.postMessage(getRdvSlots(workerData.data)); async function getRdvSlots(data){ if(data.duration == 0 || data.address_id.trim() === "" || data.reasonId.trim() === "" || data.people_id.trim() === "" ){ return false; } let details = {}; let startDate = data.sel_date; details["startDate"] = startDate; let availableDates = await generateAvailableDates(data.people_id, data.address_id, data.reasonId, startDate); let emptyAvailabilities = 0; let slots = {}; for(let key in availableDates){ slots[key] = await getSlots(key, availableDates[key],data.people_id, data.duration); } details["slots"] = slots; return JSON.parse(JSON.stringify(details)); }Y en index.js
app.get("/checkworker", async (req, res) => { const worker = new Worker("./worker.js", {workerData: {data: req.query}}); worker.once("message", result => { console.log(`${result}`); res.send(result); }); worker.on("error", error => { console.log(error); }); worker.on("exit", exitCode => { console.log(`It exited with code ${exitCode}`); }) });En esto estoy recibiendo un error de
DataCloneError: # no se pudo clonar. en Objeto. \trabajador.js:10:12
que está en la línea parentPort.postMessage(getRdvSlots(workerData.data)); en trabajador.js
Soy nuevo en nodejs, hilo de trabajo, cualquier ayuda, ¿cuál es el error en mi código?
Encontré esta pregunta porque tenía el mismo problema. Lo acabo de arreglar :) El objeto que estaba tratando de publicar en el otro hilo tenía una propiedad que estaba configurando un método asíncrono. No agregué esperar a la línea :)
Creo que esto solucionará tu problema:
parentPort.postMessage(await getRdvSlots(workerData.data));