在 Linux 下使用 Golang 进行并发编程,主要依赖于 Go 语言的 goroutine 和 channel 机制。goroutine 是 Go 语言中的轻量级线程,可以让你轻松地实现并发。channel 则是用于在 goroutine 之间传递数据的通道。
下面是一个简单的示例,展示了如何在 Linux 下使用 Golang 实现并发编程:
package main
import (
"fmt"
"sync"
"time"
)
func main() {
var wg sync.WaitGroup
// 创建一个带缓冲的 channel,用于传递数据
dataCh := make(chan int, 5)
// 启动 3 个 goroutine
for i := 1; i <= 3; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
// 模拟耗时操作
time.Sleep(time.Duration(id) * time.Second)
// 将结果发送到 channel
dataCh <- id * 10
}(i)
}
// 等待所有 goroutine 完成
wg.Wait()
close(dataCh)
// 从 channel 中读取数据并打印
for data := range dataCh {
fmt.Println("Received data:", data)
}
}
在这个示例中,我们创建了 3 个 goroutine,每个 goroutine 都会执行一个耗时操作(通过 time.Sleep
模拟),然后将结果发送到 dataCh
channel。主 goroutine 使用 sync.WaitGroup
等待所有子 goroutine 完成,然后关闭 channel。最后,主 goroutine 从 channel 中读取数据并打印。
要运行此示例,请将其保存到名为 main.go
的文件中,然后在终端中执行以下命令:
go run main.go
你应该会看到类似以下的输出:
Received data: 10
Received data: 20
Received data: 30
这个示例展示了如何在 Linux 下使用 Golang 实现并发编程。你可以根据自己的需求修改这个示例,以实现更复杂的并发逻辑。