在Golang中,实现并发编程主要依赖于两个关键字:goroutine 和 channel。goroutine 是一种轻量级的线程,它可以在程序中并发地执行任务。channel 则是一种用于在 goroutine 之间传递数据的同步机制。
以下是一个简单的示例,展示了如何在 Linux 上使用 Golang 实现并发编程:
package main
import (
"fmt"
"sync"
"time"
)
func main() {
var wg sync.WaitGroup
// 创建一个带缓冲的 channel,用于存储整数
numbers := make(chan int, 5)
// 启动一个 goroutine,用于向 channel 中发送数据
wg.Add(1)
go func() {
defer wg.Done()
for i := 1; i <= 5; i++ {
numbers <- i
time.Sleep(time.Second)
}
close(numbers)
}()
// 启动另一个 goroutine,用于从 channel 中接收数据并打印
wg.Add(1)
go func() {
defer wg.Done()
for num := range numbers {
fmt.Println("Received:", num)
}
}()
// 等待所有 goroutine 完成
wg.Wait()
}
在这个示例中,我们创建了一个带缓冲的 channel,用于存储整数。然后,我们启动了两个 goroutine:一个用于向 channel 中发送数据,另一个用于从 channel 中接收数据并打印。最后,我们使用 sync.WaitGroup 来等待所有 goroutine 完成。
要在 Linux 上运行此程序,请将其保存为 main.go 文件,然后在终端中执行以下命令:
go run main.go
这将编译并运行程序,您将看到每秒打印一个数字,共打印 5 个数字。