0

0

理解Go Goroutine的Defer行为与正确同步实践

霞舞

霞舞

发布时间:2025-11-06 18:53:13

|

629人浏览过

|

来源于php中文网

原创

理解Go Goroutine的Defer行为与正确同步实践

go主协程在子协程完成其任务前退出时,子协程中的defer语句可能不会被执行。这是由于缺乏显式同步导致的竞态条件。本文将深入解析这一现象,并提供使用sync.waitgroup或通道进行协程同步的专业实践,确保所有协程都能正常完成工作并执行其延迟函数。

引言:Goroutine Defer的“未调用”之谜

在Go语言中,defer语句用于确保函数在即将返回前执行特定的清理操作。当它与并发原语Goroutine结合使用时,有时会观察到出乎意料的行为。考虑以下Go程序示例:

package main

import (
    "fmt"
    "time"
)

func main() {
    fmt.Println("1")
    defer fmt.Println("-1") // 主协程的defer

    go func() {
        fmt.Println("2")
        defer fmt.Println("-2") // 子协程的defer
        time.Sleep(9 * time.Second) // 子协程执行长时间任务
    }()

    time.Sleep(1 * time.Second) // 主协程等待1秒
    fmt.Println("3")
}

这段代码的预期输出可能包括子协程的defer语句,例如 1 2 3 -2 -1。然而,实际输出却是 1 2 3 -1。子协程中的 fmt.Println("-2") 并没有被执行。这种现象并非Go语言的bug,而是对Goroutine生命周期和程序退出机制的误解所致。

Go程序与Goroutine的生命周期

要理解上述行为,关键在于掌握Go程序的执行流程和Goroutine的生命周期:

  1. 主Goroutine的特殊性:当Go程序启动时,main函数会在一个特殊的主Goroutine中运行。这个主Goroutine是整个程序的入口点。
  2. 程序终止条件:Go程序会在主Goroutine执行完毕后立即终止。这意味着,如果主Goroutine在其他并发运行的Goroutine完成工作之前退出,那么所有尚未完成的Goroutine(包括它们的defer)都会被强制终止,而不会有机会执行它们内部的defer语句。
  3. defer语句的执行时机:defer语句安排的函数会在其所在的函数(或Goroutine)即将返回时执行。如果Goroutine在正常返回之前就被程序终止,那么其defer队列中的函数将永远不会被调用。

在上述示例中,主Goroutine在启动子Goroutine后,仅仅通过 time.Sleep(1 * time.Second) 等待了1秒。而子Goroutine被安排执行一个长达9秒的 time.Sleep 任务。显然,主Goroutine会在子Goroutine完成其9秒睡眠之前就结束其1秒的等待,并继续执行 fmt.Println("3"),然后主Goroutine自身返回。此时,Go程序立即终止,导致仍在睡眠中的子Goroutine被强制结束,其内部的 defer fmt.Println("-2") 自然也就没有机会执行了。

误区辨析:runtime.Gosched()并非万能药

在某些情况下,开发者可能会尝试使用 runtime.Gosched() 来解决此类问题,认为它可以让出CPU,从而让其他Goroutine有机会运行。例如,在主Goroutine的末尾添加 runtime.Gosched()。然而,runtime.Gosched() 的作用是让当前Goroutine放弃CPU,让调度器有机会运行其他Goroutine。它并不能保证其他Goroutine一定会完成,更不能阻止主Goroutine在自身逻辑完成后退出。因此,runtime.Gosched() 并非解决Goroutine同步问题的通用方案,它只是一种调度提示,而非同步机制

解决方案:显式同步的重要性

Go语言倡导“不要通过共享内存来通信,而应通过通信来共享内存”的并发哲学。为了确保子Goroutine能够完成其任务并执行其defer语句,我们必须在主Goroutine中显式地等待子Goroutine的完成。Go标准库提供了多种同步原语来实现这一目标,其中最常用的是 sync.WaitGroup 和通道(channel)。

实践一:使用sync.WaitGroup等待Goroutine完成

sync.WaitGroup 是一个计数器,用于等待一组Goroutine完成。它的工作原理如下:

  • Add(delta int):增加内部计数器的值。通常在启动Goroutine之前调用,表示要等待的Goroutine数量。
  • Done():减少内部计数器的值。通常在Goroutine即将完成其工作时调用(常配合defer使用)。
  • Wait():阻塞当前Goroutine,直到内部计数器归零。

通过 sync.WaitGroup,我们可以精确地控制主Goroutine,使其等待所有子Goroutine完成后再退出。

以下是使用 sync.WaitGroup 修正后的示例代码:

package main

import (
    "fmt"
    "sync" // 引入sync包
    "time"
)

func main() {
    var wg sync.WaitGroup // 声明一个WaitGroup

    fmt.Println("1")
    defer fmt.Println("-1") // 主协程的defer

    wg.Add(1) // 增加计数器,表示要等待一个Goroutine
    go func() {
        defer wg.Done() // Goroutine完成时调用Done(),减少计数器
        fmt.Println("2")
        defer fmt.Println("-2") // 子协程的defer
        time.Sleep(3 * time.Second) // 模拟子协程执行任务
        fmt.Println("子协程任务完成")
    }()

    // 注意:这里主协程不再需要长时间的time.Sleep,
    // 因为wg.Wait()会阻塞直到子协程完成
    // time.Sleep(1 * time.Second) // 移除或缩短主协程的等待
    fmt.Println("3")
    wg.Wait() // 阻塞主协程,直到所有wg.Add(1)对应的wg.Done()都被调用
    fmt.Println("主协程等待结束")
}

输出:

AI Content Detector
AI Content Detector

Writer推出的AI内容检测工具

下载
1
3
2
子协程任务完成
-2
主协程等待结束
-1

解析:

  1. 在启动子Goroutine之前,wg.Add(1) 将等待组的计数器设置为1。
  2. 子Goroutine内部,defer wg.Done() 确保无论子Goroutine如何退出(正常完成或panic),都会调用 wg.Done() 来减少计数器。
  3. 主Goroutine在打印 "3" 之后,调用 wg.Wait()。此时,主Goroutine会阻塞,直到子Goroutine执行 wg.Done(),使计数器归零。
  4. 子Goroutine有足够的时间完成其 time.Sleep(3 * time.Second) 任务,并执行其 defer fmt.Println("-2")。
  5. 一旦子Goroutine调用 wg.Done(),主Goroutine的 wg.Wait() 解除阻塞,继续执行后续代码,并最终执行主Goroutine的 defer fmt.Println("-1")。

通过 sync.WaitGroup,我们成功地实现了主Goroutine对子Goroutine的等待,确保了子Goroutine的完整执行,包括其defer语句。

实践二:使用通道进行同步(简述)

通道(channel)是Go语言中用于Goroutine之间通信和同步的强大工具。虽然 sync.WaitGroup 更适合等待一组Goroutine完成,但通道在需要传递数据或进行更复杂协调时更为灵活。

例如,可以通过在子Goroutine完成时向一个通道发送一个信号,然后在主Goroutine中接收这个信号来达到同步的目的:

package main

import (
    "fmt"
    "time"
)

func main() {
    done := make(chan bool) // 创建一个无缓冲的布尔通道

    fmt.Println("1")
    defer fmt.Println("-1")

    go func() {
        fmt.Println("2")
        defer fmt.Println("-2")
        time.Sleep(3 * time.Second)
        fmt.Println("子协程任务完成")
        done <- true // 任务完成后发送信号
    }()

    fmt.Println("3")
    <-done // 阻塞主协程,直到从通道接收到信号
    fmt.Println("主协程等待结束")
}

这种方法同样能确保子Goroutine的 defer 语句被执行。选择 sync.WaitGroup 还是通道,取决于具体的业务场景和同步需求。如果只是简单地等待一组Goroutine完成,sync.WaitGroup 更简洁;如果需要Goroutine之间传递数据或进行更精细的控制,通道则更为合适。

总结与最佳实践

理解Go Goroutine的生命周期和程序退出机制对于编写健壮的并发程序至关重要。当启动非主Goroutine执行任务时,务必考虑如何与主Goroutine进行同步,以确保它们有机会完成工作并执行其清理逻辑(defer语句)。

关键要点:

  • Go程序在主Goroutine退出时终止,不会等待其他活跃的子Goroutine。
  • 被强制终止的Goroutine不会执行其defer栈上的函数。
  • time.Sleep 是一种粗糙且不可靠的同步方式,应避免用于Goroutine间的协调。
  • 使用 sync.WaitGroup 或通道等Go提供的同步原语,是实现Goroutine间正确同步的专业方法。

在设计并发程序时,始终将显式同步作为核心考量,这将有助于避免因Goroutine生命周期问题导致的意外行为和潜在的资源泄露。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

311

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

510

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

46

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

174

2025.08.29

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

356

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

558

2023.08.10

Go中Type关键字的用法
Go中Type关键字的用法

Go中Type关键字的用法有定义新的类型别名或者创建新的结构体类型。本专题为大家提供Go相关的文章、下载、课程内容,供大家免费下载体验。

233

2023.09.06

go怎么实现链表
go怎么实现链表

go通过定义一个节点结构体、定义一个链表结构体、定义一些方法来操作链表、实现一个方法来删除链表中的一个节点和实现一个方法来打印链表中的所有节点的方法实现链表。

441

2023.09.25

苹果官网入口直接访问
苹果官网入口直接访问

苹果官网直接访问入口是https://www.apple.com/cn/,该页面具备0.8秒首屏渲染、HTTP/3与Brotli加速、WebP+AVIF双格式图片、免登录浏览全参数等特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

7

2025.12.24

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 2.9万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号