- 前言
- Go 与操作系统
- Go 内部机制
- Go 基本数据类型
- 4 组合类型的使用
- 5 数据结构
- 6 Go package 中不为人知的知识
- 7 反射和接口
- 8 Go UNIX 系统编程
- 08.1 关于 UNIX 进程
- 08.2 flag 包
- 8.2 flag 包
- 08.3 io.Reader 和 io.Writer 接口
- 08.4 bufio 包
- 08.5 读取文本文件
- 08.6 从文件中读取所需的数据量
- 08.7 为什么我们使用二进制格式
- 08.8 读取 CSV 文件
- 08.9 写入文件
- 08.10 从磁盘加载和保存数据
- 08.11 再看strings包
- 08.12 关于bytes包
- 08.13 文件权限
- 08.14 处理 Unix 信号
- 08.15 Unix 管道编程
- 08.16 遍历目录树
- 08.17 使用 ePBF
- 08.18 关于 syscall.PtraceRegs
- 08.19 跟踪系统调用
- 08.20 User ID 和 group ID
- 08.21 其他资源
- 08.22 练习
- 08.23 总结
- 9 并发 Goroutines、Channel 和 Pipeline
- 10 Go 并发-进阶讨论
- 11 代码测试、优化及分析
- 12 Go 网络编程基础
- 13 网络编程 - 构建服务器与客户端
文章来源于网络收集而来,版权归原创者所有,如有侵权请及时联系!
09.4.2 从通道接收数据
这小节,您将了解到如何从通道读取数据。您可以执行 <-c
从名为 c
的通道读取一个值。如此,箭头方向是从通道到外部。
我将使用名为 readCh.go
的程序帮您理解怎样从通道读取数据,并它分为三部分介绍。
readCh.go
的第一段代码如下:
package main
import (
"fmt"
"time"
)
func writeToChannel(c chan int, x int) {
fmt.Println("l", x)
c <- x
close(c)
fmt.Println("2", x)
}
writeToChannel()
函数的实现与之前一样。
readCh.go
的第二部分如下:
func main() {
c := make(chan int)
go writeToChannel(c, 10)
time.Sleep(1 * time.Second)
fmt.Println("Read:", <-c)
time.Sleep(1 * time.Second)
上面的代码,使用 <-c
语法从 c
通道读取数据。如果您想要保存数据到名为 k
的变量而不只是打印它的话,您可以使用 k := <-c
表达式。第二个 time.Sleep(1 * time.Second)
语句给您时间来读取通道数据。
readCh.go
的最后一段代码如下:
_, ok := <-c
if ok {
fmt.Println("Channel is open!")
}else {
fmt.Println("Channel is closed!")
}
}
从上面的代码,您能看到一个判断一个通道是打开还是关闭的技巧。当通道关闭时,当前代码运行的还不错。但是,如果通道被打开,这里的代码就会丢弃从通道读取的值,因为在 _, ok := <-c
语句中使用了 _
字符。如果您也想在通道打开时读取通道的值,就使用一个有意义的变量名代替 _
。
执行 readCh.go
产生如下输出:
$go run readCh.go
1 10
Read: 10
Channel is closed!
$go run readCh.go
1 10
2 10
Read: 10
Channel is closed!
尽管输出不确定,但 writeToChannel()
函数的两个 fmt->Println(x)
表达式都被执行了,因为当您从通道读取数据时,它就被解除阻塞了。
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论