在Debian系統下,使用Go語言實現并發編程主要依賴于Go的輕量級線程——goroutines,以及用于同步和通信的channels。以下是一個簡單的示例,展示了如何在Go中創建并發任務并使用channel進行通信。
首先,確保你已經安裝了Go語言環境。如果沒有,請訪問Go官方網站下載并安裝適用于Debian的系統包。
創建一個名為main.go
的文件,并輸入以下代碼:
package main
import (
"fmt"
"sync"
"time"
)
func worker(id int, wg *sync.WaitGroup, ch chan<- string) {
defer wg.Done()
// 模擬耗時任務
time.Sleep(time.Second)
ch <- fmt.Sprintf("Worker %d completed", id)
}
func main() {
var wg sync.WaitGroup
numOfWorkers := 5
ch := make(chan string, numOfWorkers)
// 啟動多個goroutines
for i := 1; i <= numOfWorkers; i++ {
wg.Add(1)
go worker(i, &wg, ch)
}
// 等待所有goroutines完成
wg.Wait()
close(ch)
// 從channel中讀取并打印結果
for result := range ch {
fmt.Println(result)
}
}
在這個示例中,我們創建了一個名為worker
的函數,它接受一個整數ID、一個指向sync.WaitGroup
的指針和一個只發送字符串的channel。worker
函數模擬了一個耗時任務,然后通過channel發送一條消息。
在main
函數中,我們使用sync.WaitGroup
來等待所有goroutines完成。我們創建了一個名為ch
的channel,用于在goroutines之間傳遞消息。然后,我們啟動了多個goroutines,并在所有goroutines完成后關閉channel。最后,我們從channel中讀取并打印結果。
要運行此示例,請在終端中導航到包含main.go
文件的目錄,并運行以下命令:
go run main.go
這將輸出類似于以下內容的結果:
Worker 1 completed
Worker 2 completed
Worker 3 completed
Worker 4 completed
Worker 5 completed
這個簡單的示例展示了如何在Debian系統下使用Go語言實現并發編程。你可以根據自己的需求修改和擴展這個示例。