Node.js 中的内联子进程

Question

我熟悉浏览器中的 Web Worker，并认为 Node.js 相当于

const worker = new Worker('./worker')

是

const worker = child_process.fork('./worker')

API 有点不同，它们在底层的工作方式并不完全相同，但最终 Web Worker 和子进程似乎都做大致相同的事情；允许您运行 JavaScript 并行编码。

现在，可以使用 Web Workers 完成这件巧妙的事情，而不是通过传递包含 worker 代码的文件的 path/url 创建 Worker，您可以传递一个实际的函数。这可以通过这个简单的三行函数来实现：

function createWorker(fn) {
  var blob = new Blob(['self.onmessage = ', fn.toString()], { type: 'text/javascript' });
  var url = URL.createObjectURL(blob);

  return new Worker(url);
}

这允许您在 main/master/parent（随便你怎么称呼它）文件中内联编写工作代码，如下所示：

var myWorker = createWorker(function (e) {
  self.postMessage(e.data.toUpperCase());
});

myWorker.onMessage = function (e) {
  console.log(e.data); // HELLO FROM AN INLINE WORKER!
}

myWorker.postMessage('hello from an inline worker!')

问题
如何使用 Node.js 子进程实现相同的目的？通过查看文档，我无法判断您是否可以将模块路径以外的其他内容传递给 child_process.fork，或者是否有任何其他方法可以实现我想要的；编写内联子进程。

更新
根据@Bergi 在评论中的建议，我尝试了以下方法：

const fileSync = require('tmp').fileSync;
const writeFileSync = require('fs').writeFileSync;
const fork = require('child_process').fork;

function createWorker(fn) {
  const tmpobj = fileSync();
  writeFileSync(tmpobj.name, fn.toString()); 

  return fork(tmpobj.name);
}

var myWorker = createWorker(function (e) {
  process.send(e.toUpperCase());
});

myWorker.on('message', function (e) {
  console.log(e); // HELLO FROM AN INLINE WORKER!
})

myWorker.send('hello from an inline worker!');

唉，我收到以下错误：

C:\Users\phili\AppData\Local\Temp\tmp-165566BgqUKKM5yjR.tmp:1
(function (exports, require, module, __filename, __dirname) { function (e) {
                                                                       ^

SyntaxError: Unexpected token (
    at createScript (vm.js:80:10)
    at Object.runInThisContext (vm.js:139:10)
    at Module._compile (module.js:616:28)
    at Object.Module._extensions..js (module.js:663:10)
    at Module.load (module.js:565:32)
    at tryModuleLoad (module.js:505:12)
    at Function.Module._load (module.js:497:3)
    at Function.Module.runMain (module.js:693:10)
    at startup (bootstrap_node.js:188:16)
    at bootstrap_node.js:609:3

恐怕我在这里无法理解。知道发生了什么以及如何让它工作吗？

Answer 1

以下是最终对我有用的东西：

const fileSync = require('tmp').fileSync;
const writeFileSync = require('fs').writeFileSync;
const fork = require('child_process').fork;



function createWorker(fn) {
  const tmpobj = fileSync();
  writeFileSync(tmpobj.name, `process.on('message', ${fn.toString()})`); 

  return fork(tmpobj.name);
}

var myWorker = createWorker(function (e) {
  process.send(e.toUpperCase());
});

myWorker.on('message', function (e) {
  console.log(e); // HELLO FROM AN INLINE WORKER!
})

myWorker.send('hello from an inline worker!');

非常感谢@Bergi 帮助解决了这个问题。

Answer 2

有了 worker_threads，现在可以通过内联代码创建线程而不需要临时文件（如 snowfrogdev 所示）。

const { Worker } = require("worker_threads");
new Worker(`console.log(require("process").env.HOME)`, { eval: true });

在此示例中，将 eval 设置为 true 也允许使用 nodejs 内置函数。

Node.js 中的内联子进程

Inline Child Processes in Node.js

javascript

parallel-processing

child-process

web-worker

node.js