Go语言通过WaitGroup实现控制并发的示例详解

更新时间：2023年01月30日 10:51:37 作者：孙琦Ray

Channel能够很好的帮助我们控制并发，但是在开发习惯上与显示的表达不太相同，所以在Go语言中可以利用sync包中的WaitGroup实现并发控制，本文就来和大家详细聊聊WaitGroup如何实现控制并发

与Channel区别

Channel能够很好的帮助我们控制并发，但是在开发习惯上与显示的表达不太相同，所以在Go语言中可以利用sync包中的WaitGroup实现并发控制，更加直观。

基本使用示例

我们将之前的示例加以改造，引入sync.WaitGroup来实现并发控制。

首先我们在主函数中定义WaitGroup

var wg sync.WaitGroup

每执行一个任务，则调用Add()方法

wg.Add(1)

在主函数中我们利用Wait()方法等待并发结束

wg.Wait()

在调用的函数中，我们需要将WaitGroup以指针方式传入，否则将造成Deadlock

// 主函数内
go ready(5, &wg)

// 函数
func ready(s int, wg *sync.WaitGroup)

同时在函数执行完成后，调用wg.Done，我们使用defer实现

defer wg.Done()

完整代码

package main

import (
    "fmt"
    "sync"
    "time"
)

func ready(s int, wg *sync.WaitGroup) {

    defer wg.Done()

    fmt.Printf("Run func in a goroutine and wait for %v\n", s)
    time.Sleep(time.Second * time.Duration(s))
    fmt.Printf("Run func in a goroutine and wait for %v end\n", s)
}

func main() {

    var wg sync.WaitGroup

    wg.Add(1)
    go ready(5, &wg)

    mainWaitSec := 2
    fmt.Printf("Run Main function and wait for %v\n", mainWaitSec)
    time.Sleep(time.Second * time.Duration(mainWaitSec))
    fmt.Printf("Run Main function and wait for %v done\n", mainWaitSec)

    wg.Wait()

}

特别提示

WaitGroup传入给函数时，需要以指针方式传递，否则会造成Deadlock

多任务示例

如果不想在函数中传递WaitGroup，也可以采用以下这种方式，通过并发匿名函数的方式，在主函数逻辑中对并发进行精准控制

    var wg sync.WaitGroup

    for i := 0; i < 5; i++ {
        wg.Add(1)

        waitSec := i + 1
        go func() {
            defer wg.Done()
            ready(waitSec)
        }()
    }

完整代码

package main

import (
    "fmt"
    "sync"
    "time"
)

func ready(s int) {
    fmt.Printf("Run func in a goroutine and wait for %v\n", s)
    time.Sleep(time.Second * time.Duration(s))
    fmt.Printf("Run func in a goroutine and wait for %v end\n", s)
}

func main() {

    var wg sync.WaitGroup

    for i := 0; i < 5; i++ {
        wg.Add(1)

        waitSec := i + 1
        go func() {
            defer wg.Done()
            ready(waitSec)
        }()
    }

    mainWaitSec := 2
    fmt.Printf("Run Main function and wait for %v\n", mainWaitSec)
    time.Sleep(time.Second * time.Duration(mainWaitSec))
    fmt.Printf("Run Main function and wait for %v done\n", mainWaitSec)

    wg.Wait()

}

运行结果如下

Run Main function and wait for 2
Run func in a goroutine and wait for 2
Run func in a goroutine and wait for 4
Run func in a goroutine and wait for 5
Run func in a goroutine and wait for 1
Run func in a goroutine and wait for 3
Run func in a goroutine and wait for 1 end
Run Main function and wait for 2 done
Run func in a goroutine and wait for 2 end
Run func in a goroutine and wait for 3 end
Run func in a goroutine and wait for 4 end
Run func in a goroutine and wait for 5 end

到此这篇关于Go语言通过WaitGroup实现控制并发的示例详解的文章就介绍到这了,更多相关Go语言 WaitGroup控制并发内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

聊聊go xorm生成mysql的结构体问题
这篇文章主要介绍了go xorm生成mysql的结构体问题，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友参考下吧
2022-03-03
Go语言中循环Loop的用法介绍
这篇文章介绍了Go语言中循环Loop的用法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-07-07
Golang对MongoDB数据库的操作简单封装教程
mongodb官方没有关于go的mongodb的驱动，因此只能使用第三方驱动，mgo就是使用最多的一种。下面这篇文章主要给大家介绍了关于利用Golang对MongoDB数据库的操作简单封装的相关资料，需要的朋友可以参考下
2018-07-07
Go WEB框架使用拦截器验证用户登录状态实现
这篇文章主要为大家介绍了Go WEB框架使用拦截器验证用户登录状态实现，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-07-07
Go语言排序算法：快速、可靠的排序解决方案
Go语言提供了多种快速、可靠的排序算法,可以满足不同场景下的排序需求,其中最常用的排序算法包括快速排序、归并排序和堆排序,需要的朋友可以参考下
2023-10-10
Go语言学习之运算符使用详解
这篇文章主要介绍了Go语言中常用运算符的使用，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-04-04
使用Go语言实现远程传输文件
本文主要介绍如何利用Go语言实现远程传输文件的功能，有需要的小伙伴们可以参考学习。下面跟着小编一起来学习学习。
2016-08-08
Go语言学习之函数的定义与使用详解
这篇文章主要为大家详细介绍Go语言中函数的定义与使用，文中的示例代码讲解详细，对我们学习Go语言有一定帮助，需要的可以参考一下
2022-04-04
go语言中的协程详解
本文详细讲解了go语言中的协程，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-07-07
关于golang监听rabbitmq消息队列任务断线自动重连接的问题
这篇文章主要介绍了golang监听rabbitmq消息队列任务断线自动重连接,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-03-03