Golang — 简单地利用sync.WaitGroup并发处理批量数据
2025年10月23日 21:28 - 无间道 Go #并发编程 #Go协程
…`go package main import ( "fmt" "strconv" "sync" ) type Data struct { ID int Name string Age int } func syncRun(data []*Data) { count := len(data) var wg sync.WaitGroup // 逐个加入待处理队列 … …bChan <- v
}
//创建10个协程并行处理
workerCount := 10
for i := 0; i < workerCount; i++ {
wg.Add(1)
go worker(jobChan, &wg)
}
close(jobChan)
wg.Wait()
}
func worker(data chan *Data, wg *sync.WaitG…