tiny-worker

import { Worker } from 'tiny-worker'; // The worker's code is defined as a function. This function will be serialized and run in a separate Node.js child process. const workerFunction = function () { // In a worker thread, 'self' refers to the global scope, similar to Web Workers. self.onmessage = function (ev) { console.log(`Worker ${process.pid} received: ${ev.data}`); // Simulate some work, e.g., reversing a string const result = ev.data.split('').reverse().join(''); postMessage(`Worker ${process.pid} processed: ${result}`); }; self.onerror = function (err) { console.error(`Worker ${process.pid} error:`, err.message); }; console.log(`Worker ${process.pid} started.`); }; // Create a new worker instance using the function above. const worker = new Worker(workerFunction); // Attach a message handler to receive messages back from the worker. worker.onmessage = function (ev) { console.log('Main thread received:', ev.data); worker.terminate(); // Terminate the worker once the task is complete. }; // Attach an error handler for errors originating from the worker. worker.onerror = function (err) { console.error('Main thread error:', err.message); worker.terminate(); }; // Post a message to the worker to start a task. worker.postMessage("Hello from the main thread!"); // Add process listeners to ensure graceful shutdown of workers if the main process is terminated. process.on('SIGINT', () => { console.log('Main process SIGINT received, terminating worker...'); worker.terminate(); process.exit(0); }); process.on('SIGTERM', () => { console.log('Main process SIGTERM received, terminating worker...'); worker.terminate(); process.exit(0); });