深入理解Go语言并发编程
package main
import (
"fmt"
"sync"
"sync/atomic"
"time"
)
func main() {
var (
wg sync.WaitGroup
counter int32 = 0
)
for i := 0; i < 10; i++ {
wg.Add(1)
go func() {
defer wg.Done()
for count := 0; count < 10; count++ {
// 原子操作增加counter的值
atomic.AddInt32(&counter, 1)
time.Sleep(time.Millisecond * 100)
}
}()
}
wg.Wait() // 等待所有goroutine完成
fmt.Println("Counter value:", counter) // 打印counter的最终值
}
这段代码使用了10个goroutine来执行一个简单的任务:每个goroutine将counter的值增加10次。使用sync/atomic
包中的AddInt32
函数来确保counter的操作是原子的,防止出现竞态条件。最后,主goroutine使用sync.WaitGroup
来等待所有的辅助goroutine完成工作,然后打印出counter的最终值。这个例子有助于理解Go语言中的并发和同步的概念。
评论已关闭