douchen9855 2015-01-17 13:12
浏览 76
已采纳

golang:select语句中的通道有时仅接收(???)

I have a select statement in a go routine that receives from two channels.

for {
    fmt.Printf("Waiting for select statement ...
")
    select {
    case req := <-requestChan:
        fmt.Printf("I got a request: %v
", req)
    case <-doneChan:
        fmt.Printf("serveDatabase: Got closing signal. Stop serving.
")
        return
    }
}

If the calling function sends to first channel twice and then to second channel everything works fine:

requestChan <- Db_request{ request: "Login", beehive: "yaylaswiese" }
requestChan <- Db_request{ request: "Signup", beehive: "aziz nezir" }

fmt.Printf("Sending true to the doneChannel
")
doneChan <- true

The console output (correctly) is:

>     Waiting for select statement ...
>     I got a request: {Login yaylaswiese}
>     Waiting for select statement ...
>     Sending true to the doneChannel
>     I got a request: {Signup aziz nezir}
>     Waiting for select statement ...
>     serveDatabase: Got closing signal. Stop serving.

However, if I comment the second request like

requestChan <- Db_request{ request: "Login", beehive: "yaylaswiese" }
// requestChan <- Db_request{ request: "Signup", beehive: "aziz nezir" }

fmt.Printf("Sending true to the doneChannel
")
doneChan <- true

Then the output is

>     Waiting for select statement ...
>     I got a request: {Login yaylaswiese}
>     Waiting for select statement ...
>     Sending true to the doneChannel

So the doneChan is never received. I tried also to go into a endless loop after sending doneChan, but it has the same result.

What could that be?

  • 写回答

1条回答 默认 最新

  • dsy19811981 2015-01-17 13:22
    关注

    Most likely, your main is exiting before the other goroutine finalised. Note that they're concurrent, and once main finishes, all other goroutines are killed.

    You need to explicitly synchronize the end of your goroutines with main. You can use sync.WaitGroup for that, or another channel.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥20 docker里部署springboot项目,访问不到扬声器
  • ¥15 netty整合springboot之后自动重连失效
  • ¥15 悬赏!微信开发者工具报错,求帮改
  • ¥20 wireshark抓不到vlan
  • ¥20 关于#stm32#的问题:需要指导自动酸碱滴定仪的原理图程序代码及仿真
  • ¥20 设计一款异域新娘的视频相亲软件需要哪些技术支持
  • ¥15 stata安慰剂检验作图但是真实值不出现在图上
  • ¥15 c程序不知道为什么得不到结果
  • ¥40 复杂的限制性的商函数处理
  • ¥15 程序不包含适用于入口点的静态Main方法