快捷導(dǎo)航

golang 阻止主goroutine退出的操作

更新時(shí)間：2021年04月25日 09:56:40 作者：若塵拂風(fēng)

這篇文章主要介紹了golang 阻止主goroutine退出的操作方式，具有很好的參考價(jià)值，希望對大家有所幫助。一起跟隨小編過來看看吧

1：for

 //使用無線循環(huán)
 for{
 }

如果想退出

 for {
    reutrn 
 }

例如：啟動(dòng)三個(gè) goroutine 等待三個(gè) goroutine 執(zhí)行結(jié)束一下退出主 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

如果想退出主進(jìn)程則

c <- true

例如：啟動(dòng)三個(gè) goroutine 等待三個(gè) goroutine 執(zhí)行結(jié)束一下退出主 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

補(bǔ)充：golang使用之使用channel限制goroutine的數(shù)量

golang雖然啟動(dòng)一個(gè)goroutine很廉價(jià)但并不是可以無限制的使用的.

大多數(shù)的是用channel來限制goroutine的數(shù)量

寫了一個(gè)測試DEMO如下：

package main 
import (
 "fmt"
 "runtime"
 "time"
)
 
var (
 chanNum   = 3 //啟動(dòng)的數(shù)量
 readChan  = make(chan int)        //操作信息的channel
 limitChan = make(chan bool, 1000) //限制goroutine數(shù)量的channel，此處限制1000個(gè)
)
 
//初始人方法 
func init() {
 fmt.Println("init")
 
 for i := 0; i < chanNum; i++ {
  go Queue(i, readChan) //開啟工作池
 }
}
 
func main() {
 fmt.Println("main")
 
 //啟一個(gè)go方法 ， 無限制的往readChan里塞數(shù)據(jù)
 go func() {
  for {
   readChan <- 1
  }
 }()
 
 //監(jiān)聽到鍵盤事件后程序退出
 var input string
 fmt.Scanln(&input)
}
 
//工作池
func Queue(qid int, rchan chan int) {
 var dat int
 t := time.Tick(time.Second) //定時(shí)器，一秒
 for {
  select {
  case d := <-rchan:
   limitChan <- true //緩沖區(qū)滿之后阻塞，后面的readChan將等待
   dat += d
   go showNum(qid, dat) //每從channel接到一個(gè)數(shù)據(jù)就起一個(gè)goroutine,limitChan會限制goroutine的數(shù)量
  case <-t:
   showGoNum(qid) //定時(shí)器，每秒打印一次當(dāng)前 goroutine數(shù)量
  }
 }
}
 
func showNum(qid, i int) {
 //處理成功后在限制goroutine的Channel緩沖區(qū)里取一個(gè)數(shù)據(jù)，limitChan就可以再寫入
 //使用Defer 確保limitChan的一個(gè)緩沖區(qū)被釋放
 defer func() {
  <-limitChan
 }()
 time.Sleep(time.Millisecond * 100) //模擬程序處理耗時(shí) 
 //fmt.Println(qid, "===========", i)
}
 
//顯示當(dāng)前goroutine數(shù)量 
func showGoNum(qid int) {
 fmt.Printf("%d====numGo:==%d\n", qid, runtime.NumGoroutine())
}

執(zhí)行結(jié)果如下：

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