我有一个主题1和一个消息父，在这个父里面它包含多个子消息，比如child1…5。这些是我的主题，对于每个主题，我都有一堆工人在处理关于这个主题的信息。
主题1:主题中的父项\u消息\u主题2中的子项\u消息\u主题3:子项\u消息\u输出主题4:父项\u消息\u输出
我想要的是：等待所有5个子消息在child\u msg\u out主题上完成，然后在parent\u msg\u out主题上报告相应的父消息完成。
做这件事的好方法是什么？