golang如何判断channel已经close

互联网 19-12-31

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

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

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

_,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.

go func() {  time.Sleep(time.Second * 3)  timeout <- true  }()
go func() {  for i := 0; ; i++ {  select {      case <-timeout:          close(jobs)          return        default:          jobs <- i          fmt.Println("produce:", i)          }      }  }()

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

以上就是golang如何判断channel已经close的详细内容,更多内容请关注技术你好其它相关文章!

来源链接:
免责声明:
1.资讯内容不构成投资建议,投资者应独立决策并自行承担风险
2.本文版权归属原作所有,仅代表作者本人观点,不代表本站的观点或立场
标签: golang
上一篇:php获取远程图片并下载保存到本地的方法分析 下一篇:golang 如何实现微服务

相关资讯