golang如何判断channel已经close


本文摘自php中文网,作者尚,侵删。

channel有点类似于管道,它在goroutine同步与通信中,有着起承转合的作用,同时也是Golang实现CSP模型的关键。

golang 中大部分类型都是值类型(只有 slice / channel / map 是引用类型),读/写类型是值类型的 channel 时,如果元素 size 比较大时,应该使用指针代替,避免频繁的内存拷贝开销。

golang判断channel是否已经close的方法:

读channel的时候判断其是否已经关闭

1

_,ok := <- jobs

此时如果 channel 关闭,ok 值为 false

写入channel的时候判断其是否已经关闭

1、_,ok := <- jobs

此时如果 channel 关闭,ok 值为 false,如果 channel 没有关闭,则会漏掉一个 jobs

2、使用 select 方式

再创建一个 channel,叫做 timeout,如果超时往这个 channel 发送 true,在生产者发送数据给 jobs 的 channel,用 select 监听 timeout,如果超时则关闭 jobs 的 channel.

1

2

3

4

go func() {

 time.Sleep(time.Second * 3)

 timeout <- true

 }()

1

2

3

4

5

6

7

8

9

10

11

12

13

go func() {

 for i := 0; ; i++ {

 select {

     case <-timeout:

         close(jobs)

         return

  

     default:

         jobs <- i

         fmt.Println("produce:", i)

         }

     }

 }()

更多golang知识请关注golang教程栏目。

以上就是golang如何判断channel已经close的详细内容,更多文章请关注木庄网络博客!!

相关阅读 >>

golang read会阻塞么

(进阶)goland+jwt实现用户登录获取token

[go]golang 1.16 中 modules的主要变化更新

关于golang的那些事(八)-- 使用共享变量实现并发

golang内存分配逃逸分析

手撸golang 基本数据结构与算法 图的最短路径 贝尔曼-福特算法

整理在vscode中go编码发生的问题

聊聊dubbo-go-proxy的hostfilter

关于golang封装一个bash函数,用于执行bash命令

【发布了go-carbon1.1.1版本】完善对主流orm的支持,新增公共方法

更多相关阅读请进入《golang》频道 >>




打赏

取消

感谢您的支持,我会继续努力的!

扫码支持
扫码打赏,您说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

分享从这里开始,精彩与您同在

评论

管理员已关闭评论功能...