GoLang之图解channel之读、写、关闭

为什么这样写就不会阻塞了呢？因为下面的代码会被编译器转换为对runtime.selectnbsend的调用。

select {case ch <- 12:... foo
default:... bar
}

runtime.selectnbsend也仅仅是调用了runtime.chansend，但是会标记上非阻塞。

//编译后
if selectnbsend(ch, 12) {... foo
} else {... bar
}

func selectnbsend(c *hchan, elem unsafe.Pointer) (selected bool) {return chansend(c, elem, false, getcallerpc())
}func chansend(c *hchan, ep unsafe.Pointer, block bool, callerpc uintptr) bool

所以，如果缓冲区指望不上，又没有谁在等着recv，又或者channel为nil…
总而言之，send任务不能马上执行，需要等待。那么selectnbsend函数就会返回false，对应的协程也就不会进到sendq里等待了。

非阻塞式的读操作，会被编译器转换为对runtime.selectnbrecv或selectnbrecv2的调用，而它们也仅仅是调用了runtime.chanrecv，只不过在需要等待时会返回false。

select {case v = <-c:... foo
default:... bar
}// 被编译器转化为
if selectnbrecv(&v, c) {... foo
} else {... bar
}

//comma ok写法
select {case v, ok = <-c:... foo
default:... bar
}// 被编译器转化为
if c != nil && selectnbrecv2(&v, &ok, c) {... foo
} else {... bar
}

若channel关闭，
hchan.closed=1；
等待recv的协程接收到零值；
协程离开channel的recvq回到run queue中。

channel关闭后，
缓冲区里的数据还可以读，直到读完。
但是不能再写，否则会panic。

这些等待send的G都会离开sendq，
恢复到_Grunnable状态，
回到协程run queue中，
协程恢复执行时会发生panic。

缓冲区里的数据还可以读，直到读完。
sendq里等待的协程，
处理逻辑同无缓冲的场景一样~

channel对应的数据结构，以及读、写、关闭的基本逻辑，就简单介绍到这里~

GoLang之图解channel之读、写、关闭相关推荐

《图解HTTP》读感
<图解HTTP>读感前言一.HTTP各版本二.URL.URI 三.HTTP存在的问题四.对称加密和非对称加密五.数字证书六.SSL握手过程前言如果有一定的计算机网络基础,这 ...
文本文件 java_简单的用java实现读/写文本文件的示例
简单的用java实现读/写文本文件的示例更新时间:2008年07月26日 13:09:26 作者: 同时也展示了如果从输入流中读出来内容写入输出流中(仅限文本流) 三个例子可以独立存在,所以根据 ...
文本文件写java_Java 读/写文件文本文件的示例
/* * 简单的读/写文本文件的示例 * 这里包含了三个例子,即 * 1. 将文件读入到内存(这里是StringBuffer)的例子 * 2. 将内容中的文本写到文件 * 3. 将一个文件的内容读出来 ...
什么是.Net的异步机制(异步Stream读/写) - step 4
在前面3篇文章,我已经介绍了异步的工作原理和相关方法和参数的应用.下面我们介绍Stream流的操作, 并使用System.IO.FileStream来揭开如何开发异步的Stream(System.IO ...
java fileinputreader_java BufferedReader，FileInputStream实现文本文件读/写
/* * 简单的读/写文本文件的示例 * 这里包含了三个例子,即 * 1. 将文件读入到内存(这里是StringBuffer)的例子 * 2. 将内容中的文本写到文件 * 3. 将一个文件的内容读出来 ...
实验九使用异步方式实现文件读\写
实验九使用异步方式实现文件读\写一.实验目的了解Windows系统异步文件读/写的概念. 熟悉Windows系统文件读/写相关的API. 掌握采用异步方式实现文件读/写的相关参数设置. 二.实验 ...
mpi4py 并行读/写 numpy npy 文件的方法
本文从本人简书博客同步过来在上一篇中我们介绍了 mpi4py 中获得高性能 I/O 的方法和建议,下面我们将介绍 mpi4py 并行读/写 numpy npy 文件的方法. 在使用 mpi4py 写 ...
SPI Flash 读/写/擦除函数（适用于1MB Flash）
SPI Flash 读/写/擦除函数(适用于1MB Flash) 一.GD25Q80B 介绍二.相关宏定义三.读取FLASH设备的厂商和设备标识四.擦除FLASH设备扇区/块五.FLASH 设 ...
android 字节流读取,使用字节流读/写文件
Java 的 I/O 流提供了一条通道,这条通道可以把数据送给目的地.输入流的指向称作源,程序从指向源的输入流中读取源中的数据.输出流的指向是数据要去的目的地,程序通过向输出流中写入数据把信息传递到目 ...

GoLang之图解channel之读、写、关闭

文章目录

GoLang之图解channel之读、写、关闭

GoLang之图解channel之读、写、关闭相关推荐

最新文章

热门文章