golang 阻止主goroutine退出的操作

 更新时间:2021年04月25日 09:56:40   作者:若尘拂风  
这篇文章主要介绍了golang 阻止主goroutine退出的操作方式,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧

1:for

 //使用无线循环
 for{
 }

如果想退出

 for {
    reutrn 
 }
 

例如:启动三个 goroutine 等待三个 goroutine 执行结束一下 退出主 goroutine

var c bool = false
var nums int = 0
for i := 0; i < 3; i++ {
go func() {
fmt.Println("begin------------end")
time.Sleep(10 * time.Second)
nums++
if nums == 2 {
c = true
}
}()
}
for {
if c == true {
return
}
}

2:chan

var c = make(chan bool)
........
.......
<- c

如果想退出主进程 则

c <- true

例如:启动三个 goroutine 等待三个 goroutine 执行结束一下 退出主 goroutine

var c = make(chan bool)
var nums int = 0
for i := 0; i < 3; i++ {
go func() {
fmt.Println("begin------------")
time.Sleep(10 * time.Second)
nums++
if nums == 2 {
c <- true
}
}()
}
<-c

补充:golang使用之使用channel限制goroutine的数量

golang虽然启动一个goroutine很廉价但并不是可以无限制的使用的.

大多数的是用channel来限制goroutine的数量

写了一个测试DEMO如下:

package main 
import (
 "fmt"
 "runtime"
 "time"
)
 
var (
 chanNum   = 3 //启动的数量
 readChan  = make(chan int)        //操作信息的channel
 limitChan = make(chan bool, 1000) //限制goroutine数量的channel,此处限制1000个
)
 
//初始人方法 
func init() {
 fmt.Println("init")
 
 for i := 0; i < chanNum; i++ {
  go Queue(i, readChan) //开启工作池
 }
}
 
func main() {
 fmt.Println("main")
 
 //启一个go方法 , 无限制的往readChan里塞数据
 go func() {
  for {
   readChan <- 1
  }
 }()
 
 //监听到键盘事件后程序退出
 var input string
 fmt.Scanln(&input)
}
 
//工作池
func Queue(qid int, rchan chan int) {
 var dat int
 t := time.Tick(time.Second) //定时器,一秒
 for {
  select {
  case d := <-rchan:
   limitChan <- true //缓冲区满之后阻塞,后面的readChan将等待
   dat += d
   go showNum(qid, dat) //每从channel接到一个数据就起一个goroutine,limitChan会限制goroutine的数量
  case <-t:
   showGoNum(qid) //定时器,每秒打印一次当前 goroutine数量
  }
 }
}
 
func showNum(qid, i int) {
 //处理成功后在限制goroutine的Channel缓冲区里取一个数据,limitChan就可以再写入
 //使用Defer 确保limitChan的一个缓冲区被释放
 defer func() {
  <-limitChan
 }()
 time.Sleep(time.Millisecond * 100) //模拟程序处理耗时 
 //fmt.Println(qid, "===========", i)
}
 
//显示当前goroutine数量 
func showGoNum(qid int) {
 fmt.Printf("%d====numGo:==%d\n", qid, runtime.NumGoroutine())
}

执行结果如下:

go run channel_limit_goroutine.go

init

main

0====numGo:==1004

1====numGo:==1003

2====numGo:==1005

1====numGo:==1005

0====numGo:==1005

2====numGo:==1005

0====numGo:==1005

1====numGo:==1005

2====numGo:==1005

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。如有错误或未考虑完全的地方,望不吝赐教。

相关文章

  • go语言实现通过FTP库自动上传web日志

    go语言实现通过FTP库自动上传web日志

    这篇文章主要介绍了go语言实现通过FTP库自动上传web日志,非常简单实用,需要的小伙伴快来参考下吧。
    2015-03-03
  • Go实现线程池(工作池)的两种方式实例详解

    Go实现线程池(工作池)的两种方式实例详解

    这篇文章主要介绍了Go实现线程池(工作池)的两种方式实例详解,需要的朋友可以参考下
    2022-04-04
  • 详解以go思想去处理js异常抛弃trycatch

    详解以go思想去处理js异常抛弃trycatch

    这篇文章主要为大家介绍了详解以go思想去处理js异常抛弃trycatch,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-03-03
  • 关于Golang中for-loop与goroutine的问题详解

    关于Golang中for-loop与goroutine的问题详解

    这篇文章主要给大家介绍了关于Golang中for-loop与goroutine问题的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用golang具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧。
    2017-09-09
  • 自己动手用Golang实现约瑟夫环算法的示例

    自己动手用Golang实现约瑟夫环算法的示例

    这篇文章主要介绍了自己动手用Golang实现约瑟夫环算法的示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-12-12
  • GO语言Defer用法实例分析

    GO语言Defer用法实例分析

    这篇文章主要介绍了GO语言Defer用法,实例分析了Defer的使用技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-02-02
  • golang实现浏览器导出excel文件功能

    golang实现浏览器导出excel文件功能

    这篇文章主要介绍了golang实现浏览器导出excel文件功能,文章通过golang导出excel文件返回给web,实现浏览器导出excel文件功能,具有一定的参考价值,需要的小伙伴可以参考一下
    2022-03-03
  • Golang中Json的序列化和反序列化的使用

    Golang中Json的序列化和反序列化的使用

    本文主要介绍了Golang中Json的序列化和反序列化的使用,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-04-04
  • 从Context到go设计理念轻松上手教程

    从Context到go设计理念轻松上手教程

    这篇文章主要为大家介绍了从Context到go设计理念轻松上手教程详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-09-09
  • go程序中同一个包下为什么会存在多个同名的函数或变量(详细解析)

    go程序中同一个包下为什么会存在多个同名的函数或变量(详细解析)

    这篇文章主要介绍了go程序中同一个包下为什么会存在多个同名的函数或变量(详细解析),本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2024-05-05

最新评论