I wrote the following code and not sure why the worker is not executing:
main thread code
async runWorker(inputdata) {
return new Promise((resolve, reject) => {
try {
const testWorker = new Worker('./worker.js', {
workerData: inputData,
stdin: true
});
testWorker.on('error', (err) => {
console.log('error');
reject(err.message);
});
testWorker.on('message', (data) => {
console.log('received data');
resolve(data);
})
} catch (error) {
reject(error.message || error)
}
});
}
worker.js
import { parentPort } from "worker_threads";
async function worker() {
console.log("started");
parentPort.postMessage("fixed!");
}
worker();
What is wrong with my code?