1.通道选择
创建两个双向通道
c1 := make(chan string) //双向通道
c2 := make(chan string) //双向通道向通道写入数据
//协程1向通道1写数据go func() { c1 <- "hello world from c1" }()//协程2向通道2写数据go func() { c2 <- "hello world from c2" }()遍历所有通道读取数据
//遍历通道并选择对应通道操作for i := 0; i < 2; i++ {select {case recv1 := <-c1: //选择通道1fmt.Println("接收通道1数据:", recv1)case recv2 := <-c2: //选择通道2fmt.Println("接收通道2数据:", recv2)}}通道超时处理：使用time.After为写入条件
//单通道超时操作go func() {time.Sleep(2 * time.Second) //休眠2秒，使通道超时有效c1 <- "===再次向通道c1写入数据==="}()select {case msg := <-c1:fmt.Println("接收通道1数据:", msg)case <-time.After(1 * time.Second): //通道操作超时fmt.Println("通道操作超时")}非阻塞通道操作：
//非阻塞通道操作message := make(chan string) //处理字符串的通道signalChan := make(chan bool) //处理布尔类型的通道//不阻塞处理message通道select {case msg := <-message: //接收fmt.Println("接收message通道消息:", msg)default:fmt.Println("message:没有要处理的消息")}//向通道发送消息msgSend := "这是向通道发送的消息"select {case message <- msgSend: //发送fmt.Println("成功向message通道发送消息", msgSend)default:fmt.Println("没有要向message通道发送的消息")}//不阻塞处理signalChan通道select {case msg := <-signalChan:fmt.Println("signalChan:处理消息:", msg)default:fmt.Println("signalChan:没有要处理的消息")}//向signalChan通道发送消息select {case signalChan <- true:fmt.Println("成功向通道signalChan发送消息", <-signalChan)default:fmt.Println("没有要向signalChan通道发送的消息")}go func() { message <- "msg for channel message" }()go func() { signalChan <- false }()fmt.Println(cap(message), len(message), cap(signalChan), len(signalChan))time.Sleep(1 * time.Second)//接收多通道消息,随机处理message/signalChan通道select {case mul_msg := <-message:fmt.Println("===>接收message通道消息:", mul_msg)case mul_sig := <-signalChan:fmt.Println("===>接收signalChan通道消息", mul_sig)default:fmt.Println("无通信活动")}关闭通道处理：
//关闭通道测试jobs := make(chan int, 5) //通道缓存5条消息finish := make(chan bool) //任务完成状态//启动一个协程go func() {fmt.Println("协程已启动...")fmt.Println("jobs通道大小:", len(jobs), "容量:", cap(jobs))for {valueInChannel, getValueOK := <-jobs //取通道消息if getValueOK {fmt.Println(">>>从通道中读取的值:", valueInChannel)} else {fmt.Println("任务完成！") //调用close来关闭通道后，才会执行到这里finish <- truereturn}}}()//向通道插入5条消息for i := 0; i < 5; i++ {jobs <- (i + 1) * 5 //插入消息}fmt.Println("所有任务发送完成!!!")//关闭通道close(jobs)<-finish_, ok := <-jobs //再次读取通道数据if !ok {fmt.Println("所有任务已完成，通道无任何数据!", len(jobs), len(finish))}fmt.Println(ok)time.Sleep(time.Second * 1) //休眠1秒
)
