主頁 > 知識庫 > golang 阻止主goroutine退出的操作

golang 阻止主goroutine退出的操作

熱門標(biāo)簽:外呼系統(tǒng)用什么卡 外呼系統(tǒng)顯本地手機(jī)號 評價高的400電話辦理 壽光微信地圖標(biāo)注 百度地圖標(biāo)注后傳給手機(jī) 涿州代理外呼系統(tǒng) 電話機(jī)器人軟件免費(fèi) excel地圖標(biāo)注分布數(shù)據(jù) 阿克蘇地圖標(biāo)注

1:for

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

如果想退出

 for {
    reutrn 
 }
 

例如:啟動三個 goroutine 等待三個 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

例如:啟動三個 goroutine 等待三個 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雖然啟動一個goroutine很廉價但并不是可以無限制的使用的.

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

寫了一個測試DEMO如下:

package main 
import (
 "fmt"
 "runtime"
 "time"
)
 
var (
 chanNum   = 3 //啟動的數(shù)量
 readChan  = make(chan int)        //操作信息的channel
 limitChan = make(chan bool, 1000) //限制goroutine數(shù)量的channel,此處限制1000個
)
 
//初始人方法 
func init() {
 fmt.Println("init")
 
 for i := 0; i  chanNum; i++ {
  go Queue(i, readChan) //開啟工作池
 }
}
 
func main() {
 fmt.Println("main")
 
 //啟一個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) //定時器,一秒
 for {
  select {
  case d := -rchan:
   limitChan - true //緩沖區(qū)滿之后阻塞,后面的readChan將等待
   dat += d
   go showNum(qid, dat) //每從channel接到一個數(shù)據(jù)就起一個goroutine,limitChan會限制goroutine的數(shù)量
  case -t:
   showGoNum(qid) //定時器,每秒打印一次當(dāng)前 goroutine數(shù)量
  }
 }
}
 
func showNum(qid, i int) {
 //處理成功后在限制goroutine的Channel緩沖區(qū)里取一個數(shù)據(jù),limitChan就可以再寫入
 //使用Defer 確保limitChan的一個緩沖區(qū)被釋放
 defer func() {
  -limitChan
 }()
 time.Sleep(time.Millisecond * 100) //模擬程序處理耗時 
 //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

以上為個人經(jīng)驗(yàn),希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。

您可能感興趣的文章:
  • golang goroutine順序輸出方式
  • golang gin 框架 異步同步 goroutine 并發(fā)操作
  • Golang Goroutine的使用
  • GOLANG使用Context管理關(guān)聯(lián)goroutine的方法
  • Golang 探索對Goroutine的控制方法(詳解)
  • 關(guān)于Golang中for-loop與goroutine的問題詳解
  • 解決Golang中g(shù)oroutine執(zhí)行速度的問題

標(biāo)簽:汕頭 重慶 雞西 吐魯番 欽州 銅川 梅河口 蘭州

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《golang 阻止主goroutine退出的操作》,本文關(guān)鍵詞  golang,阻止,主,goroutine,退出,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請?zhí)峁┫嚓P(guān)信息告之我們,我們將及時溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《golang 阻止主goroutine退出的操作》相關(guān)的同類信息!
  • 本頁收集關(guān)于golang 阻止主goroutine退出的操作的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章