eventemitter.emit 方法不会在节点 js 中返回

Question

我在使用 eventemitter.emit 方法时遇到问题。

基本上这就是我想要做的。我有一个生成输出对象的长时间运行的进程（受 CPU 限制），由于这是受 CPU 限制的进程，我使用 fork() 作为单独的进程运行它。

class Producer extends EventEmitter {
    constructor() {
       this.on('MyEvent', this.produce);
    }

    produce(input) {
        var output = longRunningProcess();

        this.emit('MyEvent, output);
        process.send(output);
    }
}

var producer = new Producer();
producer.emit('MyEvent', 0); // To kick off the execution

一旦生成了每个输出，我想将其发送到父进程。并且还使用它来发出事件以产生另一个对象等等。

现在，问题是process.send(output) 似乎没有被执行。我可以看到输出在控制台中一个接一个地打印出来。但是父母似乎没有从子进程中收到任何东西。据我了解，nodejs事件循环在完成当前任务并且堆栈为空之前不应该选择新任务，但这里不是这种情况。

那么你们能帮我解决这个问题吗？

编辑：父进程代码

this.producer = ChildProcess.fork('.path/to/produer.js'silent: true });
this.producer.on('message', (data) => {
    this.miningProcess.send({ type: "StopMining", body: 0 });
});

Answer 1

在我看来，您可能正在耗尽事件循环（从不给它任何循环来处理传入事件），这可能会破坏处理网络的能力，甚至是出站网络。我建议您仅在 process.send() 完成后开始下一次迭代。

class Producer extends EventEmitter {
    constructor() {
        this.on('MyEvent', this.produce.bind(this));
    }

    produce(input) {
        let output = longRunningProcess();

        process.send(output, () => {
            // When the send finishes, start the next iteration
            // This should allow the node.js event queue to process things
            this.emit('MyEvent, output);
        });
    }
}

var producer = new Producer();
producer.emit('MyEvent', 0); // To kick off the execution

其他注意事项：

1. 您需要在事件处理程序上使用this.produce.bind(this) 而不仅仅是this.produce，以确保在调用该函数时设置正确的this 值。
2. 请记住，eventEmitter.emit() 是同步的。它不允许事件队列处理事件，eventEmitter 事件不会经过事件队列。
3. 此代码假定process.send() 回调被异步调用，并为事件循环提供足够的机会来处理任何正在等待的事件。它还确保在您开始下一次 CPU 密集型迭代之前完全发送进程间消息，这将暂时阻止事件队列处理。这样，您可以确保在再次阻塞事件队列之前完成整个通信。
4. 您可能可以使用适当的位置 setTimeout() 来启动下一次迭代，但我认为在启动下一次迭代之前确保进程间消息传递完成更可靠。
5. 仅供参考，如果您没有使用EventEmitter 来获取除此处显示的任何内容之外的任何内容，那么它并不是真正需要的。您可以直接调用对象上的方法，而不是使用 EventEmitter 事件。