Method process_messages

tutorials/13_multi_agent_coordination.py:291–322

处理收件箱中的消息。 对应 Reference: EP08 §1 Worker 的生命周期：接收任务 → 执行 → 汇报

(self)

        return f"Task completed: {task[:50]}"

    def process_messages(self):
        """
        处理收件箱中的消息。

        对应 Reference: EP08 §1
            Worker 的生命周期：接收任务 → 执行 → 汇报
        """
        messages = self.mailbox.receive(self.identity.name)
        results = []

        for msg in messages:
            if msg.msg_type == MessageType.TASK:
                print(f"    [{self.identity.name}] 收到任务: "
                      f"{msg.content[:40]}...")
                # 执行任务
                result = self.executor(msg.content)
                print(f"    [{self.identity.name}] 完成: {result[:40]}...")

                # 发送结果给 Leader
                self.mailbox.send(AgentMessage(
                    from_agent=self.identity.name,
                    to_agent=msg.from_agent,
                    msg_type=MessageType.RESULT,
                    content=result,
                ))
                results.append(result)

            elif msg.msg_type == MessageType.SHUTDOWN:
                print(f"    [{self.identity.name}] 收到关闭请求，退出")
                return "shutdown"

        return results


# ============================================================