亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

為什么通道不關閉?

為什么通道不關閉?

Go
慕桂英3389331 2022-06-01 16:19:16
對于以下代碼:package mainimport "fmt"func emit(c chan string) {    words := []string{"The", "quick", "brown", "fox", "ran", "away"}    for _, word := range words {        fmt.Printf("send %s\n", word)        c <- word    }    fmt.Printf("Close the channel\n")    close(c)}func main() {    wordChannel := make(chan string)    go emit(wordChannel)    word := <-wordChannel    fmt.Printf("receive %s \n", word)    word = <-wordChannel    fmt.Printf("receive %s \n", word)    word = <-wordChannel    fmt.Printf("receive %s \n", word)    word, ok := <-wordChannel    fmt.Printf("receive %s %t\n", word, ok)    word, ok = <-wordChannel    fmt.Printf("receive %s %t\n", word, ok)    word, ok = <-wordChannel    fmt.Printf("receive %s %t\n", word, ok)}下面是輸出:send Thesend quickreceive The receive quick send brownsend foxreceive brown receive fox truesend ransend awayreceive ran truereceive away true為什么發件人 go-routine 不關閉通道?
查看完整描述

1 回答

?
翻閱古今

TA貢獻1780條經驗 獲得超5個贊

你的maingoroutine 在沒有與 emit goroutine 協調的情況下結束以知道它已經完成。當到達結束時main,程序 - 以及它的所有 goroutines - 都會結束,無論是否有任何 goroutine 仍在處理中,除非你明確地等待它們。


關閉通道有助于將goroutine 的完成情況傳達給. 在這種情況下,使用從通道讀取的二值響應,如emitmain


word, ok = <-wordChannel

確實將通道的狀態(打開或關閉)暴露給main,但您從不使用它來控制 main 的流。此外,您有一個確切的硬編碼到 main中的讀取次數。因此,即使您使用通道關閉來控制流量,您也永遠不會嘗試最終讀取以查看關閉的通道。


幸運的是,使用 go 的解決方案非常簡單。 range在一個 go 通道上 ing 將讀取值,直到通道關閉。因此,您可以簡化您的代碼,刪除通道接收的顯式數量,并使用通道 close 來表示emit完成,所有這些都使用這個更簡潔的版本:


package main


import "fmt"


func emit(c chan string) {

    words := []string{"The", "quick", "brown", "fox", "ran", "away"}


    for _, word := range words {

        fmt.Printf("send %s\n", word)

        c <- word

    }

    fmt.Printf("Close the channel\n")

    close(c)

}


func main() {

    wordChannel := make(chan string)

    go emit(wordChannel)

    for word := range wordChannel {

      fmt.Printf("receive %s \n", word)

    }

}

當我運行它時,我得到了我認為是您想要的輸出:


$ go run t.go

send The

send quick

receive The

receive quick

send brown

send fox

receive brown

receive fox

send ran

send away

receive ran

receive away

Close the channel

這個“ rangeover a channel”語法在概念上等同于這樣的東西,只是看起來更優雅一點:


func main() {

    wordChannel := make(chan string)

    go emit(wordChannel)

    for {

      if word, ok := <-wordChannel; ok {

        fmt.Printf("receive %s \n", word)

      } else {

        break

      }

  }

}


查看完整回答
反對 回復 2022-06-01
  • 1 回答
  • 0 關注
  • 122 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號