Function parallelExample

examples/workflow-agents/main.go:78–112

parallelExample 并行执行示例

(ctx context.Context)

// parallelExample 并行执行示例
func parallelExample(ctx context.Context) {
	// 创建多个算法 Agent
	agents := []workflow.Agent{
		NewMockAgent("AlgorithmA", "方案A：快速但粗糙"),
		NewMockAgent("AlgorithmB", "方案B：慢但精确"),
		NewMockAgent("AlgorithmC", "方案C：平衡"),
	}

	// 创建 ParallelAgent
	parallel, err := workflow.NewParallelAgent(workflow.ParallelConfig{
		Name:      "MultiAlgorithm",
		SubAgents: agents,
	})
	if err != nil {
		log.Fatal(err)
	}

	// 执行
	fmt.Println("开始并行执行:")
	resultCount := 0
	reader := parallel.Execute(ctx, "求解问题")
	for {
		event, err := reader.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			log.Printf("错误: %v", err)
			continue
		}
		resultCount++
		printEvent(event)
	}
	fmt.Printf("收到 %d 个并行结果\n", resultCount)
}

// loopExample 循环优化示例
func loopExample(ctx context.Context) {