在 CentOS 下使用 Golang 實現并發控制,主要依賴于 Go 語言的 goroutine 和 channel 特性。goroutine 是輕量級的線程,可以讓你輕松地創建成千上萬個并發任務。channel 則是用于在 goroutine 之間傳遞數據和同步操作。
以下是一個簡單的示例,展示了如何在 CentOS 下使用 Golang 實現并發控制:
首先,確保你已經安裝了 Golang。如果沒有,請訪問 Golang 官網(https://golang.org/dl/)下載并安裝。
創建一個名為 main.go
的文件,并輸入以下代碼:
package main
import (
"fmt"
"sync"
"time"
)
func worker(id int, wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf("Worker %d starting\n", id)
time.Sleep(time.Second)
fmt.Printf("Worker %d done\n", id)
}
func main() {
var wg sync.WaitGroup
for i := 1; i <= 5; i++ {
wg.Add(1)
go worker(i, &wg)
}
wg.Wait()
fmt.Println("All workers done")
}
在這個示例中,我們創建了一個名為 worker
的函數,它接受一個整數 ID 和一個指向 sync.WaitGroup
的指針。worker
函數會模擬一個耗時任務(通過 time.Sleep
),然后輸出完成信息。
在 main
函數中,我們使用 sync.WaitGroup
來等待所有 goroutine 完成。我們創建了 5 個 goroutine,并為每個 goroutine 調用 wg.Add(1)
來表示有一個新的任務需要等待。然后,我們調用 wg.Wait()
來阻塞主線程,直到所有 goroutine 完成。
main.go
文件的目錄,并運行以下命令來編譯并運行程序:go build main.go
./main
這個示例展示了如何在 CentOS 下使用 Golang 實現基本的并發控制。你可以根據實際需求調整代碼,例如使用 channel 來傳遞數據或實現更復雜的同步操作。