node.js - 使用 Node.js 中的特定子进程运行作业

Question

我知道如何 fork 子进程，但我的要求是，我只想使用这个子进程来完成某些工作，例如，当单击按钮时，我需要处理表单数据以将其保存，如下所示。但是这个 post 路由必须由我创建的特定子进程执行，而不是其他子进程或主进程。

app.post('/saveuser', function(){
  user.save();
})

Answer 1

post node v11.7.0 发布了“worker_threads”模块，无需实验标志。非常适合用于单进程和多线程目的。11.7.0 之前的版本你需要传递标志 --experimental-worker 才能访问它。

访问官方文档 Worker-Threads

/* app.js */
/* your code */

const { Worker, isMainThread, threadId, Worker, parentPort, workerData } = require('worker_threads')

console.log('is this main process', isMainThread)

app.post('/saveuser', function(){

  let userSaveWorker = new Worker('name_of_another_script.js', { workerData: 'pass any type of data' })

  userSaveWorker.on('message', returnData => {
    // do whatever you wants to do with data returned from worker
    // return response to user
  })

  userSaveWorker.unref() // this will allow worker to terminate
  userSaveWorker.terminate() // this will forcefully terminate it
  // you can use it in message listner

  userSaveWorker.on('end', () => /* gets called when worker process gets terminated */);
})

现在是工作进程的脚本

name_of_another_script.js

const { Worker, isMainThread, threadId, Worker, parentPort, workerData } = require('worker_threads')

console.log('is this main process', isMainThread)

console.log('data received from parentProcess', workerData)

/* your code */
// do process & then send message back to parent

parentPort.postMessage('your processed data or result any data type')
// this will be received in app.js as .on('message') listener

你甚至可以在没有其他脚本的情况下运行工作进程将函数或代码作为字符串而不是文件名传递，并传递另一个选项 { eval: true } 它会起作用，你甚至可以传递 workerData ......