英文:
Limit number of goroutine picking task in loop
问题
我正在运行一个循环，循环次数为24次，每次调用一个下游函数。这个下游函数不能同时处理由生成的go协程提供的所有工作，我想限制只有特定数量（3或4个）的go协程被执行。
示例代码如下，如果有人能指导我正确的模式来实现这个目标，将会非常有帮助：
for i := 0; i < 24; i++ {go callSomeDownStream()}
英文:
I am running a loop - 24 times which calls a downstream that is not able to handle all the work supplied concurrently by the go-routines spawned, I want to limit that such that only a specific number (3 or 4) of go-routine gets executed.
Sample code looks like below, if anyone can point me to the right pattern to fulfil this would be a great help
for i:=0; i<24; i++ {go callSomeDownStream()}
答案1
得分: 2
你可以使用空结构体的通道来控制并发工作协程的数量。
const MAX_CONCURRENT_JOBS = 3func main() {waitChan := make(chan struct{}, MAX_CONCURRENT_JOBS)for i := 0; i < 24; i++ {waitChan <- struct{}{}go func() {callSomeDownStream()<-waitChan}()}}
这段代码中，通过创建一个容量为MAX_CONCURRENT_JOBS的空结构体通道waitChan来控制并发工作的数量。在循环中，每次向waitChan通道发送一个空结构体，表示有一个工作协程开始执行。然后，使用匿名函数启动一个协程来调用callSomeDownStream()函数，并在协程结束时从waitChan通道接收一个空结构体，表示一个工作协程结束。通过控制waitChan通道的容量，可以限制并发执行的协程数量。
英文:
You can use the channel of empty structs to control the number of concurrent worker goroutines
const MAX_CONCURRENT_JOBS = 3func main() {waitChan := make(chan struct{}, MAX_CONCURRENT_JOBS)for i:=0; i < 24; i++ {waitChan <- struct{}{}go func() {callSomeDownStream()<-waitChan}()}}
答案2
得分: 1
func callSomeDownStream(wg *sync.WaitGroup, queue chan struct{}) {defer func() {<-queuewg.Done()}()// 做一些操作}func main() {wg := sync.WaitGroup{}queue := make(chan struct{}, 3)for i := 0; i < 24; i++ {queue <- struct{}{}wg.Add(1)go callSomeDownStream(&wg, queue)}wg.Wait()close(queue)}
以上是要翻译的代码。
英文:
func callSomeDownStream(wg *sync.WaitGroup, queue chan struct{}) {defer func() {<-queuewg.Done()}()// do something}func main() {wg := sync.WaitGroup{}queue := make(chan struct{}, 3)for i := 0; i < 24; i++ {queue <- struct{}{}wg.Add(1)go callSomeDownStream(&wg, queue)}wg.Wait()close(queue)}
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论