Go語言控制并發數量的方法有以下幾種:
ch := make(chan struct{}, maxConcurrency)
for i := 0; i < totalTasks; i++ {
ch <- struct{}{} // 占用一個channel的緩沖區
go func() {
defer func() { <-ch }() // 釋放一個channel的緩沖區
// 執行并發任務
}()
}
var wg sync.WaitGroup
for i := 0; i < totalTasks; i++ {
wg.Add(1)
go func() {
defer wg.Done()
// 執行并發任務
}()
}
wg.Wait()
pool := make(chan struct{}, maxGoroutines)
for i := 0; i < maxGoroutines; i++ {
pool <- struct{}{} // 占用一個goroutine
go func() {
defer func() { <-pool }() // 釋放一個goroutine
// 執行并發任務
}()
}
以上方法都可以用來控制并發數量,根據實際場景選擇合適的方法。