Why does my code deadlock (followed by crash) on read from channel, I would expect it to block on read after the channel is read completely, but not crash. I understand it is a deadlock state as no one is writing to the channel and read blocks on it.
How can I change the code to read all the channel content and then exit from main instead of crash.
Go playground: https://play.golang.org/p/rjXZZOx1FFZ
package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
news := make(chan int, 10)
wg.Add(1)
go foo(&wg, news)
wg.Wait()
for {
fmt.Printf("reading: %v\n", <-news)
//crashes here after printing 0-9
}
}
func foo(wg *sync.WaitGroup, news chan int) {
for i:=0; i<10;i++ {
fmt.Printf("Writing\n")
news <- i
}
(*wg).Done()
}
The program deadlocks because main blocks on channel receive and there are no other goroutines that will send to that channel.
Use this approach to read all the channel content and then exit from main: main reads the channel until closed; foo writes all values and closes the channel.
func main() {
news := make(chan int, 10)
go foo(news)
// range breaks when the channel is closed
for v := range news {
fmt.Printf("reading: %v\n", v)
}
}
func foo(news chan int) {
for i := 0; i < 10; i++ {
fmt.Printf("Writing\n")
news <- i
}
// close channel to indicate that no more values will be sent.
close(news)
}
Run it on the Playground.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With