一个线程负责读取
主线程负责写入
// test02 project main.go package main import ( "fmt" "time" ) /* 一个线程负责读取 主程序负责写入 */ //负责读取i func Process(ch chan int) { for { i := <-ch fmt.Println("Process:", i) } } func main() { fmt.Println("Hello World!") ch := make(chan int, 1) go Process(ch) count := 1 for { select { case ch <- count: count = count + 1 default: time.Sleep(1e9) } } }
有疑问加站长微信联系(非本文作者)