Diseñé una función diversify() para tomar una función costosa f() y ejecutarla en paralelo en todos los núcleos de la máquina en la que se ejecuta. También configuré esto para que si f() devuelve un valor en un núcleo, todos los demás subprocesos se eliminan automáticamente. El código para eso está a continuación:
let diversify = f => { // Split a function `f` into a thread for each core of the machine. // The first thread to finish will return its result and end all others. if ( cluster.isMaster ) { let children = [] for ( let i = 0; i < os.cpus().length; i++) { children.push(cluster.fork()) } cluster.on('message', (_, msg) => { if ( msg.cmd == 'stop' ) { children.forEach(child => { child.process.kill() })} return msg.out }) } else { let out = f() process.send({ cmd: 'stop', out }) } } El problema es que después de que un proceso le dice al proceso maestro que se detenga a través de msg.cmd = 'stop' , no hay forma de devolver el msg.out de salida. De la forma en que se implementa en el código anterior, la return msg.out está dentro de una función anónima anidada dentro de la función diversificar más grande. Por lo tanto, este valor de retorno no se expone cuando ejecuta algo como diversify(() => { return true }) , lo que resulta en undefined en su lugar. ¿Hay alguna forma de devolver lo que se envía en msg.out ?
El envío de mensajes a los trabajadores es asincrónico por diseño.
Técnicamente, no hay forma de return un valor de una devolución de llamada que sea un controlador de eventos, ya que el evento puede ocurrir en cualquier momento.
La solución canónica a este problema es a través de promesas . Simplemente envuelva el cuerpo de la función en una promesa y resolve el valor en lugar de devolverlo.
const diversify = (f) => new Promise((resolve) => { // Split a function `f` into a thread for each core of the machine. // The first thread to finish will return its result and end all others. if (cluster.isMaster) { let children = []; for (let i = 0; i < os.cpus().length; i++) { children.push(cluster.fork()); } cluster.on('message', (_, msg) => { if (msg.cmd == 'stop') { children.forEach((child) => { child.process.kill(); }); } resolve(msg.out); }); } else { let out = f(); process.send({ cmd: 'stop', out }); } }); El resultado es entonces accesible in out :
const getPid = () => { return process.pid; }; diversify(() => { console.log(getPid()); return true; }).then((out) => { console.log(out); // true }); // or using async/await const diversifyAsync = async () => { const out = await diversify(() => { console.log(getPid()); return true; }); console.log(out); // true }; diversifyAsync();