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函數的邏輯，以實現不同的并行處理任務。