【資料圖】

Channel的使用示例

以下是一個使用Channel的示例程序，該程序創(chuàng)建了兩個Goroutine，并使用Channel在它們之間進行通信和同步。

package mainimport ("fmt""time")func worker(id int, jobs <-chan int, results chan<- int) {for j := range jobs {fmt.Printf("worker %d started job %d\n", id, j)time.Sleep(time.Second)fmt.Printf("worker %d finished job %d\n", id, j)results <- j * 2}}func main() {jobs := make(chan int, 100)results := make(chan int, 100)for w := 1; w <= 3; w++ {go worker(w, jobs, results)}for j := 1; j <= 9; j++ {jobs <- j}close(jobs)for a := 1; a <= 9; a++ {<-results}}

在這個示例程序中，我們定義了一個名為worker的函數(shù)，它模擬了一個工作任務(wù)。這個函數(shù)接收一個jobs的單向Channel用于接收工作任務(wù)，以及一個results的單向Channel用于發(fā)送工作結(jié)果。當(dāng)函數(shù)接收到一個工作任務(wù)時，它會等待一秒鐘，然后將工作結(jié)果發(fā)送到results的Channel中。

在main函數(shù)中，我們創(chuàng)建了兩個Channel：一個jobs的Channel用于發(fā)送工作任務(wù)，一個results的Channel用于接收工作結(jié)果。然后，我們啟動了三個Goroutine，并將它們分別分配給worker函數(shù)。接下來，我們向jobs的Channel中發(fā)送了9個工作任務(wù)，并關(guān)閉了這個Channel。最后，我們從results的Channel中接收了9個工作結(jié)果。

在這個示例程序中，我們使用Channel實現(xiàn)了工作任務(wù)的分配和工作結(jié)果的收集。通過使用Channel，我們可以輕松地實現(xiàn)Goroutine之間的通信和同步，從而使程序變得簡單和高效。