• 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

  • 相关阅读:
    2024社招面经_存储&DB&广告架构方向
    jenkins发布java项目和执行shell脚本nohup的总结
    如何在云计算平台上完成分子对接
    Spring 源码(16)Spring Bean的创建过程(7)属性填充
    BP绁炵粡缃戠粶浠跨湡,bp绁炵粡缃戠粶妯″瀷
    TS学习笔记 类型标签 联合类型 枚举类型 泛型 类型别名
    创建SpringBoot工程
    Linux Docker部署GitLab、GitLab Runner
    UUCTF部分web题解
    Flink学习12:DataStreaming API
  • 原文地址:https://blog.csdn.net/qq522044637/article/details/125408981