下面由golang教程栏目给大家介绍关于Golang channel的实现,希望对需要的朋友有所帮助!
channel是Go语言在语言级别提供的goroutine间的通信方式,可以使用channel在两个或多个goroutine之间传递消息。channel是进程内通信方式,因此通过channel传递对象的过程和调用函数时的参数传递行为比较一致,比如也可以传递指针。如果需要跨进程通信,建议使用分布式系统来解决,比如使用Socket或者HTTP等通信协议。
channel是类型相关的,也就是说,一个chennel只能传递一种类型的值,这个类型需要在声明channel时指定。注意,在GO语言中channel本身也是一个原生类型,与map之类的类型地位一样,因此channel本身在定义后也可以通过channel传递。
type hchan struct { qcount uint // 队列中当前数据的个数 dataqsiz uint // size of the circular queue buf unsafe.Pointer // 数据缓冲区,存放数据的环形数组 elemsize uint16 // channel中数据类型的大小(单个元素的大小) closed uint32 // 表示channel是否关闭标识位 elemtype *_type // 队列中的元素类型 sendx uint // 当前发送元素的索引 recvx uint // 当前接收元素的索引 recvq waitq // 接受等待队列,由recv行为(也就是<-ch)阻塞在channel上的goroutine队列 sendq waitq // 发送等待队列, 由send行为(也就是ch<-)阻塞在channel上的goroutine队列 //lock保护chann中的所有字段,以及在此通道上阻塞的sudoG中的几个字段。 //保持此锁时不要更改另一个G状态(特别是没准备好G),因为这可能会因堆栈收缩而死锁 lock mutex } //发送及接收队列的·1结构体 type waitq struct { first *sudog last *sudog }
1.创建带buffer的channel
2.向channel中写入数据
3.3 写入过程如下:
以上是关于Golang channel的实现的详细内容。更多信息请关注PHP中文网其他相关文章!