猿问

使用 gooutins 和渠道的并发受限消费者

我试图重现“良好管理资源的方法是启动固定数量的句柄 goroutines,所有这些 goroutines 都从请求通道读取。” 从Effective Go 中发现


fatal error: all goroutines are asleep - deadlock!

这个想法很简单:有 1 个队列和 1 个结果通道和几个有限数量的“工人”。


我的代码在 Go Playground


queue := make(chan *Request)

result := make(chan int)

quit := make(chan bool)

go Serve(queue, quit)

for i := 0; i < 10; i++ {

    req := Request{i, result}

    queue <- &req

}

close(queue)

for i := 0; i < 10; i++ {

    fmt.Printf("Finished %d\n", <-result)

}

fmt.Printf("All finished\n")

quit <- true

功能服务:


func handle(queue chan *Request) {

    for r := range queue {

        //process(r)

        fmt.Printf("Processing %d\n", r.i)

        r.r <- r.i


    }

}


func Serve(clientRequests chan *Request, quit chan bool) {

    MaxOutstanding := 2

    // Start handlers

    for i := 0; i < MaxOutstanding; i++ {

        go handle(clientRequests)

    }

    <-quit // Wait to be told to exit.

}

怎么了?或者可能有更简单的解决方案来实现数量有限的处理请求的工人?


牛魔王的故事
浏览 184回答 1
微课
1回答
随时随地看视频慕课网APP

相关分类

Go
我要回答