【資料圖】

Channel的使用示例

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

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}}

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

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

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