Projeto bem maneiro, tive que fazer uma solução dessa recentemente no trabalho, mas nós utilizamos pipes para a comunicação, e futuramente a gente vai precisar de mais processos comunicando entre si, mas estavamos pensando em criar um "proccess router", nesse caso cada processo vai ter um "endereço" unico e o processo router vai direcionar pra onde a mensagem tem que ir, cada processo teria sua queue de mensagens individual dentro do processo, e o router iria enviar a mensagem em uma thread diferente pra cada request de mensagem assim ele fica non-blocking. vou dar uma olhada na sua solução pra ver se eu vejo alguma forma de otimizar o processo.