使用new MessageChannel()
生成一个双向通信通道。
index.js
const { Worker } = require('worker_threads');
const path = require('path');
const w1 = new Worker(path.join(__dirname,'./worker1.js'));
const w2 = new Worker(path.join(__dirname,'./worker2.js'));
w1.once('message', value => {
w2.postMessage({
port: value.port
}, [value.port]);
});
w2.once('message', value => {
w1.postMessage({
port: value.port
}, [value.port]);
});
worker1.js
const { MessageChannel, parentPort, } = require('worker_threads');
let woker2Port;
console.log('worker1 started');
const { port1, port2 } = new MessageChannel();
port1.on('message', (value) => {
console.log(value);
});
parentPort.postMessage({
port: port2,
}, [port2]);
parentPort.on('message', value => {
if (value.port) {
woker2Port = value.port;
woker2Port.postMessage({msg:'i am worker1!'});
return;
}
});
worker2.js
const { MessageChannel, parentPort, } = require('worker_threads');
let woker1Port;
console.log('worker2 started');
const { port1, port2 } = new MessageChannel();
port1.on('message', (value) => {
console.log(value);
});
parentPort.postMessage({
port: port2,
}, [port2]);
parentPort.on('message', value => {
if (value.port) {
woker1Port = value.port;
woker1Port.postMessage({msg:'i am worker2!'});
}
});
注意:如果你在 VSCode 中调试此代码,你将看不到在 worker1.js
和 worker2.js
中的日志打印。直接运行 node index
或者使用 ndb 调试都可以正常工作!
worker_threads
模块吗? - lx1412