溫馨提示×

golang并發模型怎么使用

小億
120
2023-08-23 13:07:10
欄目: 編程語言

Golang的并發模型是通過goroutine和channel來實現的。

  1. Goroutine: Goroutine是輕量級的線程,可以同時執行多個goroutine??梢允褂藐P鍵字go來啟動一個goroutine,例如:
go func() {
// 并發執行的代碼
}()
  1. Channel: Channel是goroutine之間進行通信的機制,可以用于傳遞數據和同步goroutine的執行??梢允褂胢ake函數創建一個channel,例如:
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進行通信和同步。

0
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女