首页 / 缓存 / 退出程序时，防止无缓存的channel没有消费完的方法

退出程序时，防止无缓存的channel没有消费完的方法

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了退出程序时，防止无缓存的channel没有消费完的方法，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1055字，纯文字阅读大概需要2分钟。

内容图文

  • 参考代码

                    package main

import(
  "fmt"
  "sync"
  "time"
  "runtime"
)

var wg sync.WaitGroup

// 生产者
func Send(ch chan int){
  x:=0
  defer func(){
      if err:=recover();err!=nil && err.(runtime.Error).Error() == "send on closed channel"{
          fmt.Println(err)
          fmt.Println("即将产生的数据：",x)
      }else{
          close(ch)  //关闭的目的：不在发送数据
      }
      wg.Done()
  }()
  for i:=0;i<10;i++{
      x++
      ch <- x
  }
}

// 消费者
func Receive(ch chan int){
  defer func(){
      if err:=recover();err!=nil{
          fmt.Println(err)
          close(ch)  //关闭的目的：不要让生产者继续发送数据
          fmt.Println(<-ch)  //继续消费，输出结果为0,说明已经不会生产者已经不会再发送数据了
      }
      wg.Done()
  }()
  for x:= range ch {
      time.Sleep(time.Second)
      fmt.Println(x)
      if x==3{
          panic("发生意外的错误")  //中断主程序,但是协程还是不会关闭的
      }
  }
  fmt.Println("Receive任务结束")
}


func main(){
  fmt.Println("退出程序时，防止channel没有消费完")
  ch := make(chan int)
  wg.Add(2)
  go Send(ch)
  go Receive(ch)
  wg.Wait()
  fmt.Println("任务完成")
  _,ok:=<- ch
  fmt.Println(ok)
}

  • 输出结果

                    退出程序时，防止channel没有消费完
1
2
3
发生意外的错误
0
send on closed channel
即将产生的数据： 4
任务完成

  • 总结

    • 退出程序的时候,将生产者关闭,不会产生多余的数据给消费者消费

原文：https://www.cnblogs.com/MyUniverse/p/11664541.html

内容总结

以上是互联网集市为您收集整理的退出程序时，防止无缓存的channel没有消费完的方法全部内容，希望文章能够帮你解决退出程序时，防止无缓存的channel没有消费完的方法所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1057392.html

来源：【匿名】