统一消息系统

def process_batch(messages):

import concurrent.futures

with concurrent.futures.ThreadPoolExecutor() as executor:

executor.map(send_message, messages)

def send_message(message):

# 模拟发送消息逻辑

print(f"Sending message: {message}")

]]>

class AgentManager:

def __init__(self):

self.agents = {}

def register_agent(self, agent_id, handler):

self.agents[agent_id] = handler

def handle_message(self, agent_id, message):

if agent_id in self.agents:

return self.agents[agent_id](message)

else:

return "Unknown agent"

]]>

def batch_process_by_agents(agent_manager, messages):

from collections import defaultdict

agents_messages = defaultdict(list)

for msg in messages:

agent_id = msg['agent_id']

agents_messages[agent_id].append(msg['content'])

for agent_id, msgs in agents_messages.items():

agent_manager.handle_message(agent_id, msgs)

]]>