知识点 channel的使用

package demo_channel

import (

"fmt"

"time"
)

func main() {

//无缓存chan

ch := make(chan int)

go func() {

fmt.Println("执行")

ch <- 99 //一般放在有效代码的最后，这是由于若主线程ch取的太快的话则协程可能执行不完

fmt.Println("执行结束")

}()

a := <-ch //若没有上面的协程则程序会阻塞

time.Sleep(time.Second)

fmt.Println(a, "程序结束")

//死锁，在主线程中向无缓存的channel添加内容或在主线程中向channel添加内容超过channel缓存的个数就会出现死锁

//如：func(){

// ch:=make(chan int)

//ch<-1

// }

//这种情况在子协程中出现不会影响主线程的正常运行

//若有缓存的channel中不超过最大值则不会出现死锁


//select 简介

ch1 := make(chan int, 1)

ch2 := make(chan string, 1)

ch1 <- 1

ch2 <- "ksdj"

select { //若符合以下条件的不止一个则随机选择一个来执行，若所有条件都不满足也没有default则阻塞

case value := <-ch1:

fmt.Println(value)

case value := <-ch2:

fmt.Println(value)

default:

fmt.Println("skjd")

}


//若客户端不停地发消息则用如下结构

ch3 := make(chan int)

for i := 0; i < 10; i++ {

go func(j int) {

ch3 <- j

}(i)

}

for {

select {

case aa := <-ch3:

fmt.Println(aa)

default:

}

}
}