在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。