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

在Go語言中，可以使用goroutine和channel來實現(xiàn)多分支并行處理。goroutine是Go語言中的輕量級線程，它們在同一個操作系統(tǒng)線程上并發(fā)執(zhí)行。channel是一種用于在不同goroutine之間傳遞數(shù)據(jù)的通道。

下面是一個簡單的示例，展示了如何在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) // 創(chuàng)建3個worker goroutine

	// 啟動3個worker goroutine
	for i := 0; i < 3; i++ {
		go worker(i, input, output, &wg)
	}

	// 向input channel發(fā)送數(shù)據(jù)
	for i := 0; i < 10; i++ {
		input <- i
	}
	close(input) // 關閉input channel，表示沒有更多的數(shù)據(jù)發(fā)送

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

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

在這個示例中，我們創(chuàng)建了一個worker函數(shù)，它接收一個整數(shù)輸入，將其乘以2，然后將結果發(fā)送到輸出channel。我們創(chuàng)建了3個這樣的worker goroutine，它們從同一個輸入channel接收數(shù)據(jù)，并將結果發(fā)送到同一個輸出channel。

在main函數(shù)中，我們創(chuàng)建了輸入和輸出channel，并啟動了3個worker goroutine。然后，我們向輸入channel發(fā)送了10個整數(shù)，并關閉了輸入channel。接下來，我們等待所有worker goroutine完成，并關閉輸出channel。最后，我們從輸出channel接收結果并打印。

這個示例展示了如何在Go工作流中使用多分支并行處理。你可以根據(jù)自己的需求調(diào)整worker函數(shù)的邏輯，以實現(xiàn)不同的并行處理任務。