-
猛跑小猪
缓冲区大小是在没有发送阻塞的情况下可以发送到通道的元素数。默认情况下,通道的缓冲区大小为0(可通过来获得此值make(chan int))。这意味着每个发送都将阻塞,直到另一个goroutine从通道接收到为止。缓冲区大小为1的通道可以容纳1个元素,直到发送块为止,因此您将获得c := make(chan int, 1)c <- 1 // doesn't blockc <- 2 // blocks until another goroutine receives from the channel
-
摇曳的蔷薇
以下代码说明了对非缓冲通道的阻塞:// to see the diff, change 0 to 1c := make(chan struct{}, 0)go func() { time.Sleep(2 * time.Second) <-c}()start := time.Now()c <- struct{}{} // block, if channel size is 0elapsed := time.Since(start)fmt.Printf("Elapsed: %v\n", elapsed)您可以在此处使用代码。
-
FFIVE
package mainimport ( "fmt" "time")func receiver(ch <-chan int) { time.Sleep(500 * time.Millisecond) msg := <-ch fmt.Printf("receive messages %d from the channel\n", msg)}func main() { start := time.Now() zero_buffer_ch := make(chan int, 0) go receiver(zero_buffer_ch) zero_buffer_ch <- 444 elapsed := time.Since(start) fmt.Printf("Elapsed using zero_buffer channel: %v\n", elapsed) restart := time.Now() non_zero_buffer_ch := make(chan int, 1) go receiver(non_zero_buffer_ch) non_zero_buffer_ch <- 4444 reelapsed := time.Since(restart) fmt.Printf("Elapsed using non zero_buffer channel: %v\n", reelapsed)}结果:从通道接收消息444使用zero_buffer通道经过的时间:505.6729ms使用非zero_buffer通道经过的时间:0s