Coverage for agentos/concurrent/__init__.py: 0%

1"""AgentOS Concurrent Primitives. 

2 

3- ParallelExecutor: 异步并行执行器（fan-out/fan-in + 限流 + 超时）。 

4- FanOutExecutor: 扇出模式（race/merge/all + 结果聚合）。 

5- parallel_gather: 并行等待多个协程，支持超时和部分结果。 

6- parallel_map: 并行映射异步函数到列表。 

7""" 

8 

9from agentos.concurrent.parallel import ( 

10 ParallelExecutor, 

11 FanOutExecutor, 

12 FanOutConfig, 

13 TaskThrottler, 

14 TaskResult, 

15 TaskStatus, 

16 GatherResult, 

17 parallel_gather, 

18 parallel_map, 

19 create_parallel_agent_gather, 

20) 

21 

22__all__ = [ 

23 "ParallelExecutor", 

24 "FanOutExecutor", 

25 "FanOutConfig", 

26 "TaskThrottler", 

27 "TaskResult", 

28 "TaskStatus", 

29 "GatherResult", 

30 "parallel_gather", 

31 "parallel_map", 

32 "create_parallel_agent_gather", 

33]