channelv是什么意思？用法、例句，总结了才知道，原来channel有这么多用法

本篇文章给大家谈谈channelv是什么意思？用法、例句，以及总结了才知道，原来channel有这么多用法对应的知识点，文章可能有点长，但是希望大家可以阅读完，增长自己的知识，最重要的是希望对各位有所帮助，可以解决了您的问题，不要忘了收藏本站喔。

这篇文章总结了channel的11种常用操作，以一个更高的视角看待channel，会给大家带来对channel更全面的认识。

在介绍11种操作前，先简要介绍下channel的使用场景、基本操作和注意事项。

把channel用在数据流动的地方：

把这3种操作和3种channel状态可以组合出9种情况：

操作nil的channel正常channel已关闭channel<-ch阻塞成功或阻塞读到零值ch<-阻塞成功或阻塞panicclose(ch)panic成功panic

对于nil通道的情况，也并非完全遵循上表，有1个特殊场景：当nil的通道在select的某个case中时，这个case会阻塞，但不会造成死锁。

参考代码请看：https://dave.cheney.net/2014/03/19/channel-axioms

下面介绍使用channel的10种常用操作。

当需要不断从channel读取数据时。

使用for-range读取channel，这样既安全又便利，当channel关闭时，for循环会自动退出，无需主动监测channel是否关闭，可以防止读取已经关闭的channel，造成读到数据为通道所存储的数据类型的零值。

forx:=rangech{\nfmt.Println(x)\n}\n2.使用v,ok:=<-ch+select操作判断channel是否关闭

场景

v,ok:=<-ch+select操作判断channel是否关闭

-`true`：读到通道数据，不确定是否关闭，可能channel还有保存的数据，但channel已关闭。\n-`false`：通道关闭，无数据读到。\n

从关闭的channel读值读到是channel所传递数据类型的零值，这个零值有可能是发送者发送的，也可能是channel关闭了。

_,ok:=<-ch与select配合使用的，当ok为false时，代表了channel已经close。下面解释原因，_,ok:=<-ch对应的函数是funcchanrecv(c*hchan,epunsafe.Pointer,blockbool)(selected,receivedbool)，入参block含义是当前goroutine是否可阻塞，当block为false代表的是select操作，不可阻塞当前goroutine的在channel操作，否则是普通操作（即_,ok不在select中）。返回值selected代表当前操作是否成功，主要为select服务，返回received代表是否从channel读到有效值。它有3种返回值情况：

我们考虑_,ok:=<-ch和select结合使用的情况。

情况1：当chanrecv返回(false,false)时，本质是select操作失败了，所以相关的case会阻塞，不会执行，比如下面的代码：

funcmain(){\n\tch:=make(chanint)\n\tselect{\n\tcasev,ok:=<-ch:\n\t\tfmt.Printf("v:%v,ok:%v\\n",v,ok)\n\tdefault:\n\t\tfmt.Println("nothing")\n\t}\n}\n//结果：\n//nothing\n

情况2：下面的结果会是零值和false：

funcmain(){\n\tch:=make(chanint)\n\t//增加关闭\n\tclose(ch)\n\tselect{\n\tcasev,ok:=<-ch:\n\t\tfmt.Printf("v:%v,ok:%v\\n",v,ok)\n\t}\n}\n//v:0,ok:false\n

情况3的received为true，即_,ok中的ok为true，不做讨论了，只讨论ok为false的情况。

最后ok为false的时候，只有情况2，此时channel必然已经关闭，我们便可以在select中用ok判断channel是否已经关闭。

下面例子展示了，向channel写数据然后关闭，依然可以从已关闭channel读到有效数据，但channel关闭且没有数据时，读不到有效数据，ok为false，可以确定当前channel已关闭。

//demo_select6.go\nfuncmain(){\n\tch:=make(chanint,1)\n\t//发送1个数据关闭channel\n\tch<-1\n\tclose(ch)\n\tprint("closechannel\\n")\n\t//不停读数据直到channel没有有效数据\n\tfor{\n\t\tselect{\n\t\tcasev,ok:=<-ch:\n\t\t\tprint("v:",v,",ok:",ok,"\\n")\n\t\t\tif!ok{\n\t\t\t\tprint("channelisclose\\n")\n\t\t\t\treturn\n\t\t\t}\t\n\t\tdefault:\n\t\t\tprint("nothing\\n")\n\t\t}\n\t}\n}\n//结果\n//closechannel\n//v:1,ok:true\n//v:0,ok:false\n//channelisclose\n

更多见golang_step_by_step/channel/ok仓库中ok和select的示例，或者阅读channel源码。

需要对多个通道进行同时处理，但只处理最先发生的channel时

select可以同时监控多个通道的情况，只处理未阻塞的case。当通道为nil时，对应的case永远为阻塞，无论读写。特殊关注：普通情况下，对nil的通道写操作是要panic的。

//分配job时，如果收到关闭的通知则退出，不分配job\nfunc(h*Handler)handle(job*Job){\nselect{\ncaseh.jobCh<-job:\nreturn\ncase<-h.stopCh:\nreturn\n}\n}\n4.使用channel的声明控制读写权限

场景

//只有generator进行对outCh进行写操作，返回声明\n//<-chanint，可以防止其他协程乱用此通道，造成隐藏bug\nfuncgenerator(intn)<-chanint{\noutCh:=make(chanint)\ngofunc(){\nfori:=0;i<n;i++{\noutCh<-i\n}\n}()\nreturnoutCh\n}\n//consumer只读inCh的数据，声明为<-chanint\n//可以防止它向inCh写数据\nfuncconsumer(inCh<-chanint){\nforx:=rangeinCh{\nfmt.Println(x)\n}\n}\n5.使用缓冲channel增强并发

场景

有缓冲通道可供多个协程同时处理，在一定程度可提高并发性。

//无缓冲\nch1:=make(chanint)\nch2:=make(chanint,0)\n//有缓冲\nch3:=make(chanint,1)\n

//使用5个`do`协程同时处理输入数据\nfunctest(){\ninCh:=generator(100)\noutCh:=make(chanint,10)\nfori:=0;i<5;i++{\ngodo(inCh,outCh)\n}\nforr:=rangeoutCh{\nfmt.Println(r)\n}\n}\nfuncdo(inCh<-chanint,outChchan<-int){\nforv:=rangeinCh{\noutCh<-v*v\n}\n}\n6.为操作加上超时

场景

使用select和time.After，看操作和定时器哪个先返回，处理先完成的，就达到了超时控制的效果

funcdoWithTimeOut(timeouttime.Duration)(int,error){\n\tselect{\n\tcaseret:=<-do():\n\t\treturnret,nil\n\tcase<-time.After(timeout):\n\t\treturn0,errors.New("timeout")\n\t}\n}\nfuncdo()<-chanint{\n\toutCh:=make(chanint)\n\tgofunc(){\n\t\t//dowork\n\t}()\n\treturnoutCh\n}\n7.使用time实现channel无阻塞读写

场景

并不希望在channel的读写上浪费时间

是为操作加上超时的扩展，这里的操作是channel的读或写

funcunBlockRead(chchanint)(xint,errerror){\n\tselect{\n\tcasex=<-ch:\n\t\treturnx,nil\n\tcase<-time.After(time.Microsecond):\n\t\treturn0,errors.New("readtimeout")\n\t}\n}\nfuncunBlockWrite(chchanint,xint)(errerror){\n\tselect{\n\tcasech<-x:\n\t\treturnnil\n\tcase<-time.After(time.Microsecond):\n\t\treturnerrors.New("readtimeout")\n\t}\n}\n

注：time.After等待可以替换为default，则是channel阻塞时，立即返回的效果

所有读ch的协程都会收到close(ch)的信号

func(h*Handler)Stop(){\nclose(h.stopCh)\n//可以使用WaitGroup等待所有协程退出\n}\n//收到停止后，不再处理请求\nfunc(h*Handler)loop()error{\nfor{\nselect{\ncasereq:=<-h.reqCh:\ngohandle(req)\ncase<-h.stopCh:\nreturn\n}\n}\n}\n9.使用chanstruct{}作为信号channel

场景

使用channel传递信号，而不是传递数据时

没数据需要传递时，传递空struct

//上例中的Handler.stopCh就是一个例子，stopCh并不需要传递任何数据\n//只是要给所有协程发送退出的信号\ntypeHandlerstruct{\nstopChchanstruct{}\nreqChchan*Request\n}\n10.使用channel传递结构体的指针而非结构体

场景

channel本质上传递的是数据的拷贝，拷贝的数据越小传输效率越高，传递结构体指针，比传递结构体更高效

reqChchan*Request\n//好过\nreqChchanRequest\n11.使用channel传递channel

场景

使用场景有点多，通常是用来获取结果。

channel可以用来传递变量，channel自身也是变量，可以传递自己。

下面示例展示了有序展示请求的结果，另一个示例可以见另外文章的版本3。

packagemain\nimport(\n\t"fmt"\n\t"math/rand"\n\t"sync"\n\t"time"\n)\nfuncmain(){\n\treqs:=[]int{1,2,3,4,5,6,7,8,9}\n\t//存放结果的channel的channel\n\touts:=make(chanchanint,len(reqs))\n\tvarwgsync.WaitGroup\n\twg.Add(len(reqs))\n\tfor_,x:=rangereqs{\n\t\to:=handle(&wg,x)\n\t\touts<-o\n\t}\n\tgofunc(){\n\t\twg.Wait()\n\t\tclose(outs)\n\t}()\n\t//读取结果，结果有序\n\tforo:=rangeouts{\n\t\tfmt.Println(<-o)\n\t}\n}\n//handle处理请求，耗时随机模拟\nfunchandle(wg*sync.WaitGroup,aint)chanint{\n\tout:=make(chanint)\n\tgofunc(){\n\t\ttime.Sleep(time.Duration(rand.Intn(3))*time.Second)\n\t\tout<-a\n\t\twg.Done()\n\t}()\n\treturnout\n}\n推荐阅读

本文介绍的channel特性，大多在过去的文章中已详细介绍，可按需求阅读。

好了，文章到这里就结束啦，如果本次分享的channelv是什么意思？用法、例句和总结了才知道，原来channel有这么多用法问题对您有所帮助，还望关注下本站哦！