golang 阻止主goroutine退出的操作

2024-10-06 23:35:05

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

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

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

背景最近在学习MIT的分布式课程6.824的过程中,使用Go实现Raft协议时遇到了一些问题.分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧. 参见如下代码: for i := 0; i < len(rf.peers); i++ { DPrintf("i = %d", i) if i == rf.me { DPrintf("skipping myself #%d", rf.me) continue } go func() { DPrintf(
Golang Goroutine的使用

什么是 Goroutine goroutine 是 Go 并行设计的核心.goroutine 说到底其实就是协程,它比线程更小,十几个 goroutine 可能体现在底层就是五六个线程,Go 语言内部帮你实现了这些 goroutine 之间的内存共享. 执行 goroutine 只需极少的栈内存(大概是4~5KB),当然会根据相应的数据伸缩.也正因为如此,可同时运行成千上万个并发任务.goroutine 比 thread 更易用.更高效.更轻便. 一般情况下,一个普通计算机跑几十个线程就有点负载
GOLANG使用Context管理关联goroutine的方法

一般一个业务很少不用到goroutine的,因为很多方法是需要等待的,例如http.Server.ListenAndServe这个就是等待的,除非关闭了Server或Listener,否则是不会返回的.除非是一个API服务器,否则肯定需要另外起goroutine发起其他的服务,而且对于API服务器来说,在http.Handler的处理函数中一般也需要起goroutine,如何管理这些goroutine,在GOLANG1.7提供context.Context. 先看一个简单的,如果启动两个goro
golang gin 框架异步同步 goroutine 并发操作

goroutine机制可以方便地实现异步处理 package main import ( "log" "time" "github.com/gin-gonic/gin" ) func main() { // 1.创建路由 // 默认使用了2个中间件Logger(), Recovery() r := gin.Default() // 1.异步 r.GET("/long_async", func(c *gin.Context) {
Golang 探索对Goroutine的控制方法(详解)

前言在golang中,只需要在函数调用前加上关键字go即可创建一个并发任务单元,而这个新建的任务会被放入队列中,等待调度器安排.相比系统的MB级别线程栈,goroutine的自定义栈只有2KB,这使得我们能够轻易创建上万个并发任务,如此对性能提升不少.但随之而来的有以下几个问题: 如何等待所有goroutine的退出如何限制创建goroutine的数量(信号量实现) 怎么让goroutine主动退出探索--如何从外部杀死goroutine 本文记录了笔者就以上几个问题进行探究的过程,文中给
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++
golang开发安装go-torch火焰图操作步骤

目录安装使用另一种自定义显示方式代码修改使用查看安装 1. 安装go-torch go get github.com/uber/go-torch 2.安装FlameGraph cd $GOPATH && git clone https://github.com/brendangregg/FlameGraph.git export PATH=$PATH:$GOPATH/FlameGraph [这步一定要设置,生成火焰图时会用到] 3.安装graphviz (CentOS, R
浅谈golang二进制bit位的常用操作

golang作为一热门的兼顾性能效率的热门语言,相信很多人都知道,在编程语言排行榜上一直都是很亮眼,作为一门强类型语言,二进制位的操作肯定是避免不了的,数据的最小的单位也就是位,尤其是网络中封包.拆包,读取二进制文件等用的特别广泛, 所以学好golang二进制bit位的常用操作还是很必要的,而且很多运算尤其是乘法除法运算,CPU效率是很低的,这时候可以二进制操作代替,不多说了,上干货! package main import ( "fmt" "github.com/imro
Golang实现程序优雅退出的方法详解

目录 1. 背景 2. 常见的几种平滑关闭 2.1 http server 平滑关闭 2.2 gRPC server 平滑关闭 2.3 worker 协程平滑关闭 2.4 实现 io.Closer 接口的自定义服务平滑关闭 2.5 集成其他框架怎么做 1. 背景项目开发过程中,随着需求的迭代,代码的发布会频繁进行,在发布过程中,如何让程序做到优雅的退出? 为什么需要优雅的退出? 你的 http 服务,监听端口没有关闭,客户的请求发过来了,但处理了一半,可能造成脏数据. 你的协程 worker
golang针对map的判断,删除操作示例

本文实例讲述了golang针对map的判断,删除操作.分享给大家供大家参考,具体如下: map是一种key-value的关系,一般都会使用make来初始化内存,有助于减少后续新增操作的内存分配次数.假如一开始定义了话,但没有用make来初始化,会报错的. 复制代码代码如下: package main import ( "fmt" ) func main(){ var test = map[string]string{"姓名":"李四",&qu
golang 后台进程的启动和停止操作

启动命令我们先来个非后台运行的启动命令 func init() { startCmd := &cobra.Command{ Use: "start", Short: "Start Gonne", Run: func(cmd *cobra.Command, args []string) { startHttp() }, } startCmd.Flags().BoolVarP(&daemon, "deamon", "d&q
golang gorm框架数据库的连接操作示例

目录 1. 连接数据库 1.1 MySQL 1.2 PostgreSQL 1.3 Sqlite3 1.4 不支持的数据库 2. 迁移 2.1. 自动迁移 2.2. 检查表是否存在 2.3. 创建表 2.4. 删除表 2.5. 修改列 2.6. 删除列 2.7. 添加外键 2.8. 索引 1. 连接数据库要连接到数据库首先要导入驱动程序.例如 import _ "github.com/go-sql-driver/mysql" 为了方便记住导入路径,GORM包装了一些驱动. import
Golang中如何对MySQL进行操作详解

前言 Golang官方并没有提供数据库驱动,但通过database/sql/driver包来提供了实现驱动的标准接口.可以在Github上找到很多开源的驱动. 其中go-sql-driver/mysql是一个比较推荐的驱动,其完全支持database/sql接口. 使用这个驱动, 在项目里import进: import ( "database/sql" _ "github.com/go-sql-driver/mysql" ) 在正式使用database/sql包之前
Golang命令行进行debug调试操作

GoLang调试工具Delve 1.先获取呗: go get -u github.com/derekparker/delve/cmd/dlv 2.编写测试代码呗: func main(){ http.HandleFunc("/test",func(writer http.ResponseWriter,req *http.Request){ //TODO }) log.Fatal(http.ListenAndServe("127.0.0.1:8080",nil)) }

golang 阻止主goroutine退出的操作

1：for

2：chan

写了一个测试DEMO如下：

相关推荐

随机推荐