Learning golang on the way, I got a little confused when trying to understand the channel communications described in the memory model spec as below:
- A send on a channel happens before the corresponding receive from that channel completes.
- The closing of a channel happens before a receive that returns a zero value because the channel is closed.
- A receive from an unbuffered channel happens before the send on that channel completes.
- The kth receive on a channel with capacity C happens before the k+Cth send from that channel completes.
The first 2 rules are clear and easy to understand, while I really got confused about the 3rd rule, which seems opposite to others... Did I miss anything special about unbuffered channel? Or am I correct If I take it like the below with the example in the spec:
var c = make(chan int)
var a string
func f() {
a = "hello, world"
<-c // A
}
func main() {
go f()
c <- 0 // B
print(a)
}
For an unbuffered channel, the send operation(B) is blocked until the receiver gets ready to receive the value(A)? (like: B starts and does not return until A executes) Is it accurate?
And I find the following statements in Effective Go spec, but there's still discrepancy from my understanding... So can someone please explain this in a simple and straightforward way?
Receivers always block until there is data to receive. If the channel is unbuffered, the sender blocks until the receiver has received the value. If the channel has a buffer, the sender blocks only until the value has been copied to the buffer; if the buffer is full, this means waiting until some receiver has retrieved a value.
The sentence you've highlighted is the simple explanation you are looking for.
If the channel is unbuffered, the sender blocks until the receiver has received the value.
It's another way of saying point 3:
A receive from an unbuffered channel happens before the send on that channel completes.
When you send on an unbuffered channel, the sender blocks until the receiver has taken the value. This means the receive happens before the send completes.
A buffered channel is different, because the value has somewhere to go. If you're still confused, an example might help:
Say I want to leave a package at your house:
For an unbuffered channel, the send operation(B) is blocked until the receiver gets ready to receive the value(A)? (like: B starts and does not return until A executes) Is it accurate?
Yes. This is correct.
For an unbuffered channel, the send operation(B) is blocked until the receiver gets ready to receive the value(A)? (like: B starts and does not return until A executes) Is it accurate?
Yes, this is accurate. Like the documentation says if a channel is unbuffered then sender will block until the value has been received. If the value is never received you will get a deadlock and the program will time out, like in this example:
var c = make(chan int)
func main() {
c <- 0
println("Will not print")
}
So an unbuffered channel will block at the send operation until the receiver is ready to receive the value, even if that takes a while. With a buffered channel however the blocking will take place at the receive operation. This example shows how the unbuffered channel waits for the value to be received, but the buffered does not:
package main
import "time"
var c chan int
var a string
func f() {
time.Sleep(3)
a = "hello, world"
<-c // A
}
func test() {
a = "goodbye"
go f()
c <- 0 // B
println(a)
}
func main() {
// Unbuffered
c = make(chan int)
test()
// Buffered
c = make(chan int, 1)
test()
}
Outputs:
hello, world
goodbye