Golang的并發模型是通過goroutine和channel來實現的。
go func() {
// 并發執行的代碼
}()
ch := make(chan 數據類型)
發送和接收數據可以使用<-運算符,例如:
ch <- 數據 // 發送數據到channel
數據 = <-ch // 從channel接收數據
以下是一個使用goroutine和channel實現并發模型的示例代碼:
package main
import (
"fmt"
"time"
)
func worker(id int, jobs <-chan int, results chan<- int) {
for j := range jobs {
fmt.Println("worker", id, "processing job", j)
time.Sleep(time.Second) // 模擬耗時操作
results <- j * 2
}
}
func main() {
numJobs := 5
jobs := make(chan int, numJobs)
results := make(chan int, numJobs)
// 啟動3個goroutine來處理任務
for i := 1; i <= 3; i++ {
go worker(i, jobs, results)
}
// 發送任務到jobs channel
for j := 1; j <= numJobs; j++ {
jobs <- j
}
close(jobs)
// 從results channel接收結果
for r := 1; r <= numJobs; r++ {
fmt.Println(<-results)
}
}
在上面的示例中,主函數創建了兩個channel,一個用來傳遞任務(jobs),一個用來傳遞結果(results)。
然后,主函數啟動了三個goroutine來處理任務,每個goroutine會從jobs channel中接收任務,并將處理結果發送到results channel中。
最后,主函數從results channel中接收結果并打印出來。
這個示例展示了一個簡單的并發模型,其中多個goroutine并行執行任務,并通過channel進行通信和同步。