dmux 工作流¶

Input Task
    ↓
[Dispatcher]
    ↓
├─ Worker 1 → Task A
├─ Worker 2 → Task B
├─ Worker 3 → Task C
    ↓
[Result Merger]
    ↓
Unified Output

tasks = [
    Task(id=1, work="process data A"),
    Task(id=2, work="process data B"),
    Task(id=3, work="process data C"),
]

dispatcher.run_parallel(tasks, workers=3)

results = dispatcher.get_results()
merged = merge_results(results)