在golang中,可以使用goroutine和channel來控制并發數量。以下是一些常用的方法:
import (
"sync"
)
func main() {
var wg sync.WaitGroup
maxConcurrency := 10 // 并發數量
for i := 0; i < maxConcurrency; i++ {
wg.Add(1)
go func() {
defer wg.Done()
// 執行任務
}()
}
wg.Wait()
}
func main() {
maxConcurrency := 10 // 并發數量
taskCh := make(chan int, maxConcurrency)
for i := 0; i < maxConcurrency; i++ {
go func() {
for task := range taskCh {
// 執行任務
}
}()
}
// 發送任務到channel
for i := 0; i < 100; i++ {
taskCh <- i
}
close(taskCh)
}
這些方法都可以有效地控制并發數量,根據實際情況選擇合適的方法。