go sum(a[len(a)/2:], c)
// 接收两个 goroutine 发送的计算结果
x, y := <-c, <-c
fmt.Println(x, y, x+y)
}
channel 可以带有一个缓冲区(buffer)来缓存被传递的值,向 channel 中发送时只有缓冲区满的情况下会阻塞,接收 channel 中的值时只有在缓冲区空的情况下阻塞:
package main
import "fmt"
func main() {
// 创建 channel,缓冲区长度为 2
c := make(chan int, 2)
// 由于 channel 的缓冲区长度为 2
// 因此发送不会阻塞
c <- 1
c <- 2
fmt.Println(<-c)
fmt.Println(<-c)
}
发送者可以调用 close 来关闭 channel,接收者可以检测到 channel 是否被关闭:
// 这里的 ok 为 false 表示已经没有值可以接收了,并且 channel 被关闭了
v, ok := <-ch
不要向已经关闭的 channel 发送值了(will cause a panic)。
我们可以使用 for range 来接收 channel 中的值:
package main
import "fmt"
func fibonacci(n int, c chan int) {
x, y := 0, 1
for i := 0; i < n; i++ {
c <- x
x, y = y, x+y
}
// 必须要关闭 c
close(c)
}
func main() {
c := make(chan int, 10)
go fibonacci(cap(c), c)
// 这里 for 和 range 组合使用
// 不断的接收 c 中的值一直到它被关闭
for i := range c {
fmt.Println(i)
}
}
通常来说,我们不需要主动的关闭 channel。但有时候接收者必须被告知已经没有值可以接收了,这时候主动关闭是必要的,例如终止 for range 循环。
使用 select 语句可以让一个 goroutine 等待多个通讯操作。select 会阻塞直到某个 case 能够运行,如果同时存在多个可执行的,那么将随机选择一个:
package main
import "fmt"
func fibonacci(c, quit chan int) {
x, y := 0, 1
for {
select {
case c <- x:
x, y = y, x+y










