在 Go 語言中,函數和 Goroutine 實作了並發程式設計。 Go 函數可以透過 go 關鍵字並發執行,而 Goroutine 是輕量級線程,透過分配新堆疊並執行給定的函數來實現並發。在實戰案例中,互斥鎖(sync 套件)用於防止資料競爭,而 Context(context 套件)用於控制並發函數的取消和截止。
Go 函數與Goroutine 在不同並發函式庫中的實作
Go 提供了多種並發原語,使開發者可以輕鬆編寫並發程式。在本文中,我們將探討兩個最常用的並發庫:
函數
Go 函數可以並行執行,從而實現並發。可以使用下列語法來建立並發函數:
go func() { // 并发执行的代码 }
Goroutine
#Goroutine 是 Go 輕量級線程,可以並行執行。建立 Goroutine 時,它將被指派一個新的堆疊並開始執行給定的函數。可以使用以下語法來建立 Goroutine:
go func() { // 并发执行的代码 }()
實戰案例:互斥鎖
互斥鎖用於協調對共享資源的訪問,防止資料競爭。 sync 套件提供了 Mutex
類型,我們可以使用它來保護共享變數。
import ( "sync" "fmt" ) var ( count int mu sync.Mutex ) func increment() { mu.Lock() count++ mu.Unlock() } func main() { for i := 0; i < 1000; i++ { go increment() } fmt.Println(count) // 输出: 1000 }
實戰案例:Context
Context 用於傳遞請求或操作的取消狀態。 context 套件提供了 Context
和 CancelFunc
類型,我們可以使用它們來控制並發函數。
import ( "context" "fmt" "time" ) func main() { // 创建一个 Context,并在 1 秒后取消 ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() go func() { // 在 Context 被取消之前,不断打印 for { select { case <-ctx.Done(): fmt.Println("Context cancelled") break default: fmt.Println("Still running...") time.Sleep(100 * time.Millisecond) } } }() // 等待 Goroutine 完成或 Context 被取消 <-ctx.Done() }
在不同的並發庫中,函數和 Goroutine 的實作可能略有不同,但它們的核心概念仍然相同。同步類型用於協調對共享資源的訪問,而 Context 用於管理並發函數的取消和截止。
以上是golang函數與goroutine在不同並發函式庫中的實現的詳細內容。更多資訊請關注PHP中文網其他相關文章!