解决go在函数退出后子协程的退出问题
来源:脚本之家
时间:2023-01-26 21:49:10 161浏览 收藏
在Golang实战开发的过程中,我们经常会遇到一些这样那样的问题,然后要卡好半天,等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《解决go在函数退出后子协程的退出问题》,聊聊退出、go函数、子协程,希望可以帮助到正在努力赚钱的你。
该问题来源于自己在读fabric源码时,看到的一个测试代码,在一个函数中启用协程,然后该函数退出了,由于平常没有这样处理过,以及受原有c++函数域的影响,认为函数退出,子协程应该也退出了呀。
这其实是自己对go协程的理解不到位引起的,go的协程作用域不是在某个函数中的,当然,如果那个函数是main函数,就符合要求了。
该代码为solo算法的测试代码:
func goWithWait(target func()) *waitableGo {
wg := &waitableGo{
done: make(chan struct{}),
}
go func() {
target()//该协程会阻塞在这
close(wg.done)//用来对外通知
}()
//外边结束,里边还不结束吗?
return wg
}
// This test checks that if consenter is halted before a timer fires, nothing is actually written.
func TestHaltBeforeTimeout(t *testing.T) {
batchTimeout, _ := time.ParseDuration("1ms")
//support的构造还不清楚
support := &mockmultichannel.ConsenterSupport{
Blocks: make(chan *cb.Block),
BlockCutterVal: mockblockcutter.NewReceiver(),
SharedConfigVal: &mockconfig.Orderer{BatchTimeoutVal: batchTimeout},
}
defer close(support.BlockCutterVal.Block)
bs := newChain(support)
//bs.main是solo算法的启动函数,是个死循环,处理函数
wg := goWithWait(bs.main)
defer bs.Halt()//中止
syncQueueMessage(testMessage, bs, support.BlockCutterVal)
bs.Halt()
select {
case
<h2>遇到该问题后,我写了几个测试:</h2>
<p>单纯的函数退出,是不会影响协程的</p>
<pre class="brush:plain;">
package main
import "fmt"
var ch chan int
func test() int {
ch = make(chan int)
go func() {
for {
fmt.Println(
<p>我经常在main里边直接写协程的测试demo,main退出会结束主协程,之后会强制结束子协程,一般不会遇到上述在普通函数退出的问题,也没仔细思考,所以分析源码时有点困惑。</p>
<h2>子协程启动子协程,父协程的退出,并没有影响到子协程</h2>
<pre class="brush:plain;">
liudeMacBook-Pro:~ liu$ cat tmp.go
package main
import (
"fmt"
"time"
)
func test() {
go func() { //父协程
defer func() {
fmt.Println("exit dad")
}()
go func() { //子协程
defer func() {
fmt.Println("exit kid")
}()
}()
}()
}
func main() {
test()
time.Sleep(time.Second)
}
liudeMacBook-Pro:~ liu$ go run tmp.go
exit dad
exit kid
补充:golang中父子协程生命周期问题,以及通过context优雅关闭子协程
背景
上次基于mysql实现分布式锁,今天经过测试发现问题,主要是协程不断获取锁的逻辑存在问题,因为获取锁的协程挂掉之后,但其新生成的用来不断更新锁的协程并不会退出,导致锁一直不能被释放,究其原因如下
原因
通过下面代码即可说明
fmt.Println("main 函数 开始...")
go func() {
fmt.Println("父 协程 开始...")
go func() {
for {
fmt.Println("子 协程 执行中...")
timer := time.NewTimer(time.Second * 2)
<blockquote>
<p>main 函数 开始...</p>
<p>父 协程 开始...</p>
<p>子 协程 执行中...</p>
<p>子 协程 执行中...</p>
<p>子 协程 执行中...</p>
<p>父 协程 退出...</p>
<p>子 协程 执行中...</p>
<p>子 协程 执行中...</p>
<p>main 函数 退出</p>
</blockquote>
<p><strong>由此可以看出:</strong></p>
<p>main 函数退出,所有协程退出</p>
<p>协程无父子关系,即在父协程开启新的协程,若父协程退出,不影响子协程</p>
<h2>解决方式</h2>
<p>通过context上下文来解决,当然也可以通过channel管道来解决,context解决方式如下:</p>
<pre class="brush:plain;">
fmt.Println("main 函数 开始...")
go func() {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
fmt.Println("父 协程 开始...")
go func(ctx context.Context) {
for {
for {
select {
case
<blockquote>
<p>main 函数 开始...</p>
<p>父 协程 开始...</p>
<p>子 协程 执行中...</p>
<p>子 协程 执行中...</p>
<p>子 协程 执行中...</p>
<p>父 协程 退出...</p>
<p>子 协程 接受停止信号...</p>
<p>main 函数 退出</p>
</blockquote>
<p>以上为个人经验,希望能给大家一个参考,也希望大家多多支持golang学习网。如有错误或未考虑完全的地方,望不吝赐教。</p><p>到这里,我们也就讲完了《解决go在函数退出后子协程的退出问题》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于golang的知识点!</p>
声明:本文转载于:脚本之家 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
-
342 收藏
-
286 收藏
-
337 收藏
-
163 收藏
-
210 收藏
最新阅读
更多>
-
147 收藏
-
400 收藏
-
332 收藏
-
297 收藏
-
445 收藏
-
419 收藏
-
329 收藏
-
483 收藏
-
214 收藏
-
262 收藏
-
432 收藏
-
440 收藏
课程推荐
更多>
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 485次学习