//使用无线循环 for{ }
如果想退出
for { reutrn }
例如:启动三个 goroutine 等待三个 goroutine 执行结束一下 退出主 goroutine
var c bool = falsevar nums int = 0for 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 = 0for 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:==%dn', 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
以上为个人经验,希望能给大家一个参考,也希望大家多多支持优爱好网。如有错误或未考虑完全的地方,望不吝赐教。
相关文章:
1. 怎么让div+css兼容ie6ie7ie8ie9和FireFoxChrome等浏览器2. requestAnimationFrame使用示例详解3. 基于JavaScript实现图片裁剪功能4. React优雅的封装SvgIcon组件示例5. uniapp自定义验证码输入框并隐藏光标6. 详解JavaScript中原始数据类型Symbol的使用7. JavaScript深拷贝方法structuredClone使用8. uniapp 手机验证码输入框实现代码(随机数、倒计时、隐藏手机号码中间四位)可以直接使用9. 使用Node.js实现Clean Architecture方法示例详解10. Jquery使用原生AJAX方法请求数据