Go工作流中的多分支并行处理

在Go语言中，可以使用goroutine和channel来实现多分支并行处理。goroutine是Go语言中的轻量级线程，它们在同一个操作系统线程上并发执行。channel是一种用于在不同goroutine之间传递数据的通道。

下面是一个简单的示例，展示了如何在Go工作流中使用多分支并行处理：

package main

import (
	"fmt"
	"sync"
)

func worker(id int, input <-chan int, output chan<- int, wg *sync.WaitGroup) {
	defer wg.Done()

	for i := range input {
		output <- i * 2
	}
}

func main() {
	input := make(chan int)
	output := make(chan int)

	var wg sync.WaitGroup
	wg.Add(3) // 创建3个worker goroutine

	// 启动3个worker goroutine
	for i := 0; i < 3; i++ {
		go worker(i, input, output, &wg)
	}

	// 向input channel发送数据
	for i := 0; i < 10; i++ {
		input <- i
	}
	close(input) // 关闭input channel，表示没有更多的数据发送

	// 等待所有worker goroutine完成
	wg.Wait()
	close(output) // 关闭output channel

	// 从output channel接收结果并打印
	for result := range output {
		fmt.Println(result)
	}
}

在这个示例中，我们创建了一个worker函数，它接收一个整数输入，将其乘以2，然后将结果发送到输出channel。我们创建了3个这样的worker goroutine，它们从同一个输入channel接收数据，并将结果发送到同一个输出channel。

在main函数中，我们创建了输入和输出channel，并启动了3个worker goroutine。然后，我们向输入channel发送了10个整数，并关闭了输入channel。接下来，我们等待所有worker goroutine完成，并关闭输出channel。最后，我们从输出channel接收结果并打印。

这个示例展示了如何在Go工作流中使用多分支并行处理。你可以根据自己的需求调整worker函数的逻辑，以实现不同的并行处理任务。