如何在Node.js worker线程之间共享上下文并传递变量与函数

核心前提 #

Node.js 内置的 worker_threads 模块天生是内存隔离的，线程间所有传输的内容都需要经过结构化克隆算法处理，该算法本身不支持传递函数、闭包、绑定了上下文的对象这类非序列化内容，所以不存在能让你直接在子线程访问原线程变量/上下文的方案，这是底层设计决定的，不是第三方库能突破的限制。

1. 有没有支持该需求的第三方库？ #

没有能完全实现“传递原线程上下文、子线程直接访问原线程变量和函数”的第三方库。
目前常见的worker封装库（比如workerpool、threads.js）只能做到简化调用流程：你可以把要执行的逻辑传给库，库会自动完成序列化、线程分发、结果回传的流程，但本质还是把函数代码序列化后传到子线程重新编译执行，原线程的闭包、上下文绑定的内容完全无法传递过去，子线程执行逻辑用到的依赖也需要单独在子线程环境引入。

2. 是否可以在线程之间传递匿名函数？ #

原生能力不支持 #

直接向postMessage传入函数会直接抛出DataCloneError错误，结构化克隆算法不支持处理函数类型。

可替代的实现方案 #

你可以手动把匿名函数序列化为字符串，传到子线程后用new Function或者eval重新生成函数实例，这种方案有两个严格限制：

• 仅支持纯函数，函数内部不能依赖任何原线程的闭包变量、上下文内容，否则子线程执行时会报变量未定义错误
• 有极高的安全风险，如果反序列化的函数内容不可信，会存在代码注入漏洞，不建议在生产环境使用

示例代码

主线程代码

const { Worker } = require('worker_threads');

// 注意：该匿名函数不能引用任何外部闭包变量
const calculateSum = (a, b) => a + b;

const worker = new Worker('./worker.js', {
  workerData: {
    taskString: calculateSum.toString(),
    execParams: [3, 5]
  }
});

worker.on('message', result => console.log('执行结果：', result));

子线程（worker.js）代码

const { parentPort, workerData } = require('worker_threads');
// 反序列化生成函数
const execTask = eval(`(${workerData.taskString})`);
const result = execTask(...workerData.execParams);
parentPort.postMessage(result);

额外建议 #

如果需要在线程间共享数据，优先使用SharedArrayBuffer实现二进制数据共享，或者通过postMessage传递普通可序列化的JSON数据，不要尝试绕过隔离限制传递上下文和函数，会带来大量不可控的线程安全问题。

内容的提问来源于stack exchange，提问作者dev3dev