channel的基本使用

1、管道分类

读写管道
只读管道
只写管道
缓冲通道：创建时指定大小（如果不指定默认为非缓冲通道）

2、正确使用管道

管道关闭后自能读，不能写
写入管道不能超过管道的容量cap，满容量还写则会阻塞
管道为空时，如果没有关闭，则继续读取会阻塞当前线程，直到有东西写入管道

m,ok:=<-intChan  //ok用来检测产是否已经关闭 false代表关闭了，关闭了m就是默认值

一般如下操作才可以判断读取是否完毕，如果写进程没有关闭管道则说明还有东西要写

v,ok:=<-intChan

if !ok{

	fmt.Println("读取完毕")

	break

}

3、管道遍历与访问

for-range访问
select访问（常用）

for-range

//gor-range  如果管道没有数据同时还没有关闭  则会一直阻塞等待

	go func() {

		for i:=range c{ //注意这里没有ok判断是否关闭了 只有一个返回值

			fmt.Println(i)

		}

	}()

下面这种情况for-range会阻塞,1秒后打印1，和 “关闭了”，如果没写同时又没有关闭，那么则会一直阻塞

	ch := make(chan int)

	go func() {

		time.Sleep(time.Second)

		//close(ch)

		ch<-1

	}()

	go func() {

	for i:=range ch{

		log.Println(i)

	}

   log.Println("关闭了")

	}()

	time.Sleep(time.Hour)

下面的这种情况，for-range在一秒后会结束，同时打印“关闭了”

	ch := make(chan int)

	go func() {

		time.Sleep(time.Second)

		close(ch)

		//ch<-1

	}()

	go func() {

		for i:=range ch{

			log.Println(i)

		}

		log.Println("关闭了")

	}()

	time.Sleep(time.Hour)

select

select会随机选择case里面没有阻塞的管道进行读取或写入，如果都阻塞则执行default语句，一般select都会伴随一个default语句

	c:=make(chan string,2)

	send:= func(v string) {

		select {

		case c<-v:log.Println("输入",v)

		default:log.Println("缓冲区已经满")

		}

	}

	receive:= func() string {

		select {

		case v:=<-c:return v

		default:

			log.Println("缓冲区空")

			return ""

		}

	}

	send("h1")

	send("h2")

	send("h3") //输入失败

	log.Println(receive())

	log.Println(receive())

	log.Println(receive()) //取失败

当管道关闭时，select也会执行成功，如下打印了一秒‘等' 之后就会结束，这里没有往管道写东西，所以结束时打印的是默认值0

	ch := make(chan int)

	//go func() {

	//	ch <- 1

	//}()

	go func() {

		time.Sleep(time.Second)

		close(ch)

	}()

	go func() {

		for {

			time.Sleep(time.Microsecond*500)

			select {

			case v := <-ch:

				log.Println(v)

				return

			default:

				log.Println("等")

			}

		}

	}()

	time.Sleep(time.Hour)

4、阻塞情况

1、没有关闭，同时管道元素为0，读进程阻塞

2、没有关闭，同时管道元素已经满，则写进程阻塞，无缓冲管道的话则会阻塞在写，直到有人读

3、关闭管道，读光了还读，则读取出来的是对应类型管道的默认空值，在一个关闭通道进行写操作会报错

	ch:=make(chan int,1)

	ch<-1

	close(ch)

	log.Println(<-ch) //1

	log.Println(<-ch) //0

	log.Println(<-ch)//0

	a,ok:=<-ch

	log.Println(a,ok)//0 false

关闭管道，还写，则报错
无缓冲=堵塞，缓冲=非堵塞无缓冲是同步，有缓冲是异步

像下面这个无缓冲管道，没人读则一直阻塞，只会打印A1，有一个管道读走了才会继续执行写操作，就比如快递员来发快递，只会等你拿走快递才会离开，否则一直在等你来拿

	ch := make(chan int)

	go func() {

		for{

			log.Println("A1")

			time.Sleep(time.Second)

			//close(ch)

			ch<-1

			log.Println("A2")

		}

	}()

那如果我把cap设置成1呢？

	ch := make(chan int,1)

	go func() {

		for{

			log.Println("A1")

			time.Sleep(time.Second)

			//close(ch)

			ch<-1

			log.Println("A2")

		}

	}()

打印如下，可以写一个

2020/03/21 20:02:59 A1

2020/03/21 20:03:00 A2

2020/03/21 20:03:00 A1

其他关于通道的使用可以看这两篇博客

go通道的常见使用场景.

go通道的优雅关闭.

巴特西

channel的基本使用

1、管道分类

2、正确使用管道

3、管道遍历与访问

4、阻塞情况

最新文章

热门文章