我看了一些我很久以前寫的代碼，當(dāng)時 go1.3 發(fā)布（我可能錯了）。代碼在這里下面的代碼曾經(jīng)按預(yù)期工作，但現(xiàn)在因為我已經(jīng)更新go到當(dāng)前的主版本（go version devel +bd1efd5 Fri Jul 31 16:11:21 2015 +0000 darwin/amd64），最后的輸出消息c <- "FUNC 1 DONE"沒有打印，代碼正常工作play.golang.org。我做錯了什么，還是這是一個錯誤？package mainimport ("fmt";"sync";"time")func test(c chan string, wg *sync.WaitGroup) { defer wg.Done() fmt.Println("EXEC FUNC 1") time.Sleep(3 * time.Second) c <- "FUNC 1 DONE"}func test1(c chan string, wg *sync.WaitGroup) { defer wg.Done() fmt.Println("EXEC FUNC 2") time.Sleep(2 * time.Second) c <- "FUNC 2 DONE"}func main() { ch := make(chan string) var wg sync.WaitGroup wg.Add(2) go test(ch, &wg) go test1(ch, &wg) go func(c chan string) { for txt := range c { fmt.Println(txt) } }(ch) wg.Wait()}更新：我不是說，以上是完成這些類型工作的最佳方式，但我認(rèn)為它沒有任何問題。同時運行它go version go1.4.2 darwin/amd64會返回預(yù)期的輸出。
1 回答
Helenr
TA貢獻1780條經(jīng)驗 獲得超4個贊
你的代碼一直有這個錯誤。您的程序在 main 退出之前設(shè)法打印了所有消息，這只是偶然的。
為了使其正常工作，我會反轉(zhuǎn)您擁有wg.Wait()和通道接收的位置，以便您可以異步關(guān)閉通道。這種方式接收操作是阻塞的main，一旦所有發(fā)送操作完成，通道就會關(guān)閉。
func main() {
ch := make(chan string)
var wg sync.WaitGroup
wg.Add(2)
go test(ch, &wg)
go test1(ch, &wg)
go func() {
wg.Wait()
close(ch)
}()
for txt := range ch {
fmt.Println(txt)
}
}
- 1 回答
- 0 關(guān)注
- 198 瀏覽
添加回答
舉報
0/150
提交
取消