dongpo5264 2015-10-09 10:20
浏览 34
已采纳

单通道执行常规死锁

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 time
   found <-true
}

func main {

   // ....
   found:=make(chan bool)
   var wg sync.WaitGroup
   itemFound:=false
       Loop:
          for i:=0; i<limit; i++ {
              select {
                 case <-found:
                    itemFound = true
                    break Loop
                 default:
                    if(some_check) {
                       wg.Add(1)
                       go workerRoutine(mdata,found,&wg)
                    }
              }
       }

   wg.Wait()

   // use itemFound
}
  • 写回答

1条回答 默认 最新

  • dougao7801 2015-10-09 10:47
    关注

    One possible solution is to avoid select statement and use separate goroutine for receiver (or sender, or both). Example:

    package main    
    import "sync"
    
    func worker(res chan bool, wg *sync.WaitGroup) {
        res <- true
        wg.Done()
    }
    
    func receiver(res chan bool, wg *sync.WaitGroup) {
        for range res {
        }
        wg.Done()
    }
    
    func main() {
        var wg, wg2 sync.WaitGroup
        wg.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()
    }
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 seatunnel-web使用SQL组件时候后台报错,无法找到表格
  • ¥15 fpga自动售货机数码管(相关搜索:数字时钟)
  • ¥15 用前端向数据库插入数据,通过debug发现数据能走到后端,但是放行之后就会提示错误
  • ¥30 3天&7天&&15天&销量如何统计同一行
  • ¥30 帮我写一段可以读取LD2450数据并计算距离的Arduino代码
  • ¥15 飞机曲面部件如机翼,壁板等具体的孔位模型
  • ¥15 vs2019中数据导出问题
  • ¥20 云服务Linux系统TCP-MSS值修改?
  • ¥20 关于#单片机#的问题:项目:使用模拟iic与ov2640通讯环境:F407问题:读取的ID号总是0xff,自己调了调发现在读从机数据时,SDA线上并未有信号变化(语言-c语言)
  • ¥20 怎么在stm32门禁成品上增加查询记录功能