Tengo el siguiente código en el archivo Index.js

 try { pool = Pool(() => spawn(new Worker('./SubFlows')), workers); for (let i = 0; i < dataset.length; i += 1) { const task = pool.queue(async (subFlows) => { await subFlows(dataset[i], i); }); myTasks.push(task); } } catch (err) { throw err; } finally { await Promise.allSettled(myTasks); await pool.completed(true); await pool.terminate(true); }

Subflujos.js:

 async function subFlows(data, threadId) { try { //business logic goes here. } catch (e) { throw e; } } expose(subFlows);

El código anterior es inconsistente y, en algún momento, se ejecuta bien según el "conjunto de datos. longitud", pero la mayoría de las veces arroja el siguiente mensaje de error.

 C:\Users\achu\Documents\New_folder\firetv\framework-v3.0\node_modules\observable-fns\dist\observable.js:42 setTimeout(() => { throw error; }, 0); ^ Error: Timeout: Did not receive an init message from worker after 10000ms. Make sure the worker calls expose(). at Timeout._onTimeout (C:\Users\achu\Documents\New_folder\firetv\framework-v3.0\node_modules\threads\dist\master\spawn.js:35:53) at listOnTimeout (internal/timers.js:557:17) at processTimers (internal/timers.js:500:7)

Alguien me puede ayudar a resolver este mensaje de error