在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语言实现并发编程。你可以根据自己的需求修改和扩展这个示例。