创建带有缓冲区的channel:
ch := make(chan int, 10)
则该缓冲区最多可以不断接收10次写入,然后10次读出
package main import "fmt" import "strconv" func main() { ch := make(chan int, 10) // 创建一个具有10个缓存区的channel for { select { case ch <- 1 : fmt.Println("read data") case i := <- ch : fmt.Println("write data : " + strconv.Itoa(i)) } } }
有疑问加站长微信联系(非本文作者)