您的位置:首頁 >公共 >

go的數(shù)據(jù)類型-其他數(shù)據(jù)類型-channel(二)_環(huán)球速遞

2023-04-21 16:14:16 來源:騰訊云


(相關(guān)資料圖)

Channel的使用示例

以下是一個使用Channel的示例程序,該程序創(chuàng)建了兩個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}}

在這個示例程序中,我們定義了一個名為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之間的通信和同步,從而使程序變得簡單和高效。

標(biāo)簽:

相關(guān)文章