(相關(guān)資料圖)
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之間的通信和同步,從而使程序變得簡單和高效。
標(biāo)簽: