在Golang中,實現并發的主要方法是使用goroutines和channels。goroutines是輕量級的線程,它們在Go運行時中被調度和管理。channels用于在goroutines之間傳遞數據。以下是一個簡單的示例,展示了如何在Ubuntu上使用Golang進行并發處理。
首先,確保你已經安裝了Go。如果沒有,請訪問https://golang.org/dl/ 下載并安裝適用于Ubuntu的Go版本。
接下來,創建一個名為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
// 啟動5個goroutines
for i := 1; i <= 5; i++ {
wg.Add(1)
go worker(i, &wg)
}
// 等待所有goroutines完成
wg.Wait()
fmt.Println("All workers done")
}
在這個示例中,我們定義了一個名為worker
的函數,它接受一個整數ID和一個指向sync.WaitGroup
的指針。worker
函數模擬了一個耗時任務,然后打印出完成信息。main
函數中,我們啟動了5個goroutines來執行worker
函數,并使用sync.WaitGroup
來等待所有goroutines完成。
要運行此程序,請在終端中導航到包含main.go
文件的目錄,并運行以下命令:
go run main.go
你將看到類似以下的輸出:
Worker 1 starting
Worker 2 starting
Worker 3 starting
Worker 4 starting
Worker 5 starting
Worker 1 done
Worker 2 done
Worker 3 done
Worker 4 done
Worker 5 done
All workers done
這個示例展示了如何在Ubuntu上使用Golang進行并發處理。你可以根據需要修改worker
函數以執行實際任務,并根據需要啟動更多的goroutines。