英文:
go routine deadlock with single channel
问题
我最近开始学习Go，并且在一个问题上遇到了困难。我有一个简单的Go协程，它要么返回值，要么将值推送到一个通道中。我的主函数将工作委托给这个协程，直到满足条件或数据用尽为止。这段代码似乎在"found"通道上发生了死锁。我做错了什么？
- 有多个工作协程
- 项目可能同时在多个工作协程中找到
- 一旦找到项目，所有工作协程都应该停止。
func workerRoutine(data Data, found chan bool, wg *sync.WaitGroup){defer (*wg).Done()// 数据处理// 返回false时退出// 多个协程可以同时设置这个值found <- true}func main() {// ....found := make(chan bool)var wg sync.WaitGroupitemFound := falseLoop:for i := 0; i < limit; i++ {select {case <-found:itemFound = truebreak Loopdefault:if some_check {wg.Add(1)go workerRoutine(mdata, found, &wg)}}}wg.Wait()// 使用itemFound}
以上是你提供的代码。请问你需要我对其进行什么样的翻译？
英文:
I started learning go recently and I am stuck on a problem.
I have a simple go routine which either returns or pushes value to a channel.
And my main fn delegates work to this routine till it meets condition or data is exhausted.
This code seem to deadlock on "found" channel. What am I doing wrong?
- There are multiple workers
- Item can be found in more than one worker at the same time
- Once item is found, all workers should be stopped.
.
func workerRoutine(data Data, found chan bool, wg *sync.WaitGroup){defer (*wg).Done()// data processing// return on false// multiple routines can set this at the same timefound <-true}func main {// ....found:=make(chan bool)var wg sync.WaitGroupitemFound:=falseLoop:for i:=0; i<limit; i++ {select {case <-found:itemFound = truebreak Loopdefault:if(some_check) {wg.Add(1)go workerRoutine(mdata,found,&wg)}}}wg.Wait()// use itemFound}
答案1
得分: 1
一种可能的解决方案是避免使用select语句，并为接收器（或发送器，或两者）使用单独的goroutine。
示例代码：
package mainimport "sync"func worker(res chan bool, wg *sync.WaitGroup) {res <- truewg.Done()}func receiver(res chan bool, wg *sync.WaitGroup) {for range res {}wg.Done()}func main() {var wg, wg2 sync.WaitGroupwg.Add(1)wg2.Add(10)found := make(chan bool)go receiver(found, &wg)for i := 0; i < 10; i++ {go worker(found, &wg2)}wg2.Wait()close(found)wg.Done()}
这段代码的作用是创建一个接收器和多个工作器的并发程序。接收器从通道found中接收数据，而工作器向通道found发送数据。通过使用sync.WaitGroup来同步goroutine的执行，确保所有工作器完成后再关闭通道。
英文:
One possible solution is to avoid select statement and use separate goroutine for receiver (or sender, or both).
Example:
package mainimport "sync"func worker(res chan bool, wg *sync.WaitGroup) {res <- truewg.Done()}func receiver(res chan bool, wg *sync.WaitGroup) {for range res {}wg.Done()}func main() {var wg, wg2 sync.WaitGroupwg.Add(1)wg2.Add(10)found := make(chan bool)go receiver(found, &wg)for i := 0; i < 10; i++ {go worker(found, &wg2)}wg2.Wait()close(found)wg.Done()}
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论