为什么要使用channelchannel的介绍channel的基本使用定义/声明channel管道的遍历和关闭channel的关闭channel的遍历goroutine和channel结合应用实例1应用实例2案例注意事项为什么要使用channel

前面使用全局变量加锁同步来解决goroutine的通讯但不完美

1.主线程在等待所有goroutine全部完成时间很难确定我们这里设置10秒仅仅是过段2.如果主线程休眠时间长了会加长等待时间如果等待时间短了可能还有routine处于工作状态这时也会随主线程的退出而销毁3.通过全局白能量加锁同步来实现通讯也并不利用多个协程对全局变量的读写操作4.上面种种分析都在互换一个新的通讯机制-----channel

1.channel本质就是一个数据结构-队列2.数据是先进先出3.线程安全多goroutine访问时不需要加锁就是说channel本身就是线程安全的4.channel是有类型的一个string的channel只能存放string类型数据

定义/声明channel

{//演示一下管道的使用//创建一个可以存放三个int类型的俄管道var

intChan

3)//看看intChan是什么fmt.Printf(intChan的值%v

intChan,

num//看看管道的长度和cap(容量fmt.Printf(channel

len

cap(intChan))//在没有使用协程的情况下如果我们管道数据已经全部取出在取就会报告deadlock

channel

使用内置函数close可以关闭channel当channel关闭后就不能再想channel写数据了但是仍然可以从给channel读取数据

1.在遍历时如果channel没有关闭则会出现deadlock的错误

2.在遍历时如果channel已经关闭则会出现正常遍历数据遍历完后就会退出遍历

package

200close(intChan)//这时不能够再写入到channel//intChan

n1)//遍历管道intChan2

在遍历时如果channel没有关闭责护出现deadlock的错误close(intChan2)for

range

i)time.Sleep(time.Second)}close(intChan)

//关闭

{break}time.Sleep(time.Second)fmt.Printf(readData读到数据%v\n,

v)}//readData读取完数据后即任务完成exitChan

trueclose(exitChan)

exitChan)//time.Sleep(time.Second

10)for

lock原因是intChan容量是10而带点吗writeData会写入50个数据因此就会阻塞在writeData的ch-i

package

num}}fmt.Println(有一个primeNum协程因为取不到数据退出)//这里还不能关闭primeChan//向exitChan写入trueexitChan

true

putNum(intChan)//开启四个协程从intChan取出数据并判断是否为素数//如果是就放入到primeChanfor

{go

{-exitChan}//当我们从exitChan去出了4个结果就可以放心关闭primeChanclose(primeChan)}()//遍历primeNum把结果输出for

{res,

{break}//将结果输出fmt.Printf(素数%d\n,

注意事项

1.channel可以声明为只读或者只写性质2.channel只读和只写的最佳实践案例

package

{//管道可以声明为只读或者只写//默认情况下管道是双向的//var

chan1

3.使用select可以解决从管道取数据的阻塞问题4.goroutine中使用recover解决携程中出现panic导致程序奔溃问题

说明如果我们起了一个协程但是这个协程出现了panic如果我们没有捕获这个panic就会造成整个程序崩溃这是我们可以在goroutine中使用recover来捕获panic进行处理这样及时这个协程发生的问题但是主线程仍然不受影响