发布于2026-07-13 阅读(0)
扫一扫,手机访问
说到Go语言的并发,核心利器无非就是goroutine和channel。在Ubuntu环境下,怎么把它们用好、用得稳,其实有套路可循。下面直接上干货,配合代码示例,一步到位。

先看第一个:用go关键字启动一个新的goroutine,就像这样:
go func() {
// 这里是你想要并发执行的代码
}()
第二个要点:如果需要等待一组goroutine全部完成,sync.WaitGroup是标准答案。它在主流程里加计数,每个goroutine做完后减计数,最后统一等待。来看一个完整的例子:
package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(1) // 为每个goroutine增加计数
go func(i int) {
defer wg.Done() // 当goroutine完成时减少计数
fmt.Printf("Goroutine %d\n", i)
}(i)
}
wg.Wait() // 等待所有goroutines完成
}
第三个关键机制:channel——goroutine之间的数据管道。生产者和消费者通过它安全传递数据,无需额外锁。下面这个例子演示了一个无限生成数据的goroutine,主协程消费到10后退出:
package main
import "fmt"
func main() {
data := make(chan int)
go func() {
for i := 0; ; i++ {
data <- i // 将数据发送到channel
}
}()
for num := range data {
fmt.Println(num)
if num >= 10 {
break
}
}
}
最后,当多个goroutine需要访问同一份共享数据时,就必须加锁保护了。sync.Mutex或sync.RWMutex是Go推荐的方案。不过注意,下面的代码里特意省去了wg.Wait()的完整声明——在实际项目中一定要保证所有goroutine执行完毕再输出结果:
package main
import (
"fmt"
"sync"
)
var counter int
var mutex sync.Mutex
func main() {
for i := 0; i < 5; i++ {
go func() {
mutex.Lock() // 在访问共享数据之前加锁
counter++
mutex.Unlock() // 在访问共享数据之后解锁
}()
}
// 等待所有goroutines完成
wg.Wait()
fmt.Println("Counter:", counter)
}
掌握这几招,在Ubuntu下用Go处理并发问题就游刃有余了。核心思想无非是:该用goroutine就用,该上channel就上,数据竞争的地方别忘了锁。熟练之后,你会发现Go的并发模型比传统多线程简洁得多。
售后无忧
立即购买>office旗舰店
售后无忧
立即购买>office旗舰店
售后无忧
立即购买>office旗舰店
售后无忧
立即购买>office旗舰店
正版软件
正版软件
正版软件
正版软件
正版软件
1
2
3
7
8