• GO语言-goroutine协程的使用


    前言

            协程的英文coroutine,go语言中的协程为goroutine。Go是并发语言,而不是并行语言。

            go语言的协程创建十分简单,只需要在调用的函数前面加上go关键字,程序就会同事运行一个新的goroutine。

            但是goroutine中没有返回值,会忽略返回值。所以往往需要通过channel进行goroutine之间的通信。

    goroutine使用

    1. func main() {
    2. go mytest()
    3. for i := 0; i < 100; i++ {
    4. fmt.Println("主函数输出:", i)
    5. }
    6. }
    7. func mytest() {
    8. for i := 0; i < 500; i++ {
    9. fmt.Println("goroutine中输出数字:", i)
    10. }
    11. }

    通过这个简单的示例输出,可以总结goroutine的两个特点:

    1. goroutine协程中的函数执行和主函数的执行是同时的,输出内容是交替的。
    2. 主程序结束后,即使子goroutine没有执行完成,也会随主程序一同结束。

    sync包-WaitGroup-同步等待组

            一般情况下,主程序结束后,子goroutine就会结束。

            为了让主程序等待子groutine执行完成,一种方法是使用sleep。但是sleep存在一个问题是,我们没办法知道子goroutine需要执行的具体时长,只能尽量放长sleep的时间。

            所以我们可以使用到sync包的WaitGroup解决主进程等待子goroutine的问题。

    1. var wg sync.WaitGroup
    2. func main() {
    3. wg.Add(1) //定义WaitGroup队列长度,长度为1
    4. go mytest()
    5. for i := 0; i < 100; i++ {
    6. fmt.Println("主函数输出:", i)
    7. }
    8. wg.Wait() //主程序最后,等待WaitGroup队列为0时再退出
    9. }
    10. func mytest() {
    11. for i := 0; i < 500; i++ {
    12. fmt.Println("goroutine中输出数字:", i)
    13. }
    14. wg.Done() //相当于wg.Add(-1),一个goroutine结束,调用wg.Done(),队列减一
    15. }

    var wg sync.WaitGroup        声明同步等待组

    wg.Add(1)        主函数中,定义WaitGroup队列长度

    wg.Done()        子goroutine中,函数最后调用,相当于将WaitGroup队列长度-1

    wg.Wait()        主函数中,在主函数的最后,等待WaitGroup队列长度为0

  • 相关阅读:
    实例讲解昇腾 CANN YOLOV8 和 YOLOV9 适配
    Linux磁盘常见知识
    RDB.js:适用于 Node.js 和 Typescript 的终极对象关系映射器
    【算法04】二分法常见题型
    zip-zip(子函数调用)
    金蝶云星空表单插件实现父窗体打开子窗体,并携带参数到子窗体
    二分法查找方法
    Spring Bean作用域简介说明
    目标检测DiffusionDet: Diffusion Model for Object Detection
    ICE常见编译和运行(异常)错误
  • 原文地址:https://blog.csdn.net/qq522044637/article/details/125408981