Как узнать, когда все работники кластера поднялись?

Question

Я ищу для начальной загрузки кластера узлов с методами запуска и остановки.

Я хотел написать что-то похожее на:

myCluster.start().then(()=>{
    return myCluster.stop().then(()=>{console.log('smooth stop! nice.')});
}).catch(err=>{console.log('something went wrong')});

Как я могу точно сказать, когда все мои работники работают?

PS: это не должно быть с обещаниями.

Answer 1

Мне удалось разработать решение, отправив сообщение от работника мастеру, как только работник прослушивает:

private sendMaster(pid: number, msg: ClusterMessage) {
    process.send({ pid, msg });
}

 self.server.listen(self.options.port, () => {
       self.sendMaster(process.pid, ClusterMessage.WORKER_LISTENING);
       resolve();
    }).on('error', () => {
       logError('Failed to start the server on port %O', self.options.port);
       reject();
});

И в мастер-коде я бы взял такие сообщения:

cluster.on('message', (worker, data) => {
    logInfo('Process %O listening on port %O', data.pid, self.options.port);
    self.startedWorkersCount++;
    if (self.startedWorkersCount === self.options.workers) {
       logInfo('Server ready');
       resolve(self.startedWorkersCount);
    }
 });

Вы можете проверить мой код более подробно здесь