Go语言goroutine并发编程

并发与并行

并发是编程里面一个非常重要的概念,Go语言在语言层面天生支持并发。
并发:同一时间段内执行多个任务。
并行:同一时刻执行多个任务。
Go语言的并发通过goroutine实现。goroutine类似于线程,属于用户态的线程,我们可以根据需要创建成千上万个goroutine并发工作。goroutine是由Go语言的运行时(runtime)调度完成,而线程是由操作系统调度完成。非用户态的线程即为系统态线程,用户态线程比系统态线程开销要小。

goroutine简介

在Go语言中,goroutine可以做到程序员只需要定义很多个任务,让系统去帮助我们把这些任务分配到CPU上实现并发执行。goroutine是由Go的运行时(runtime)调度和管理的。Go程序会智能地将 goroutine 中的任务合理地分配给每个CPU。Go语言之所以被称为现代化的编程语言,就是因为它在语言层面已经内置了调度和上下文切换的机制。

goroutine使用

只需要在调用函数的时候在前面加上go关键字,就可以为一个函数创建一个goroutine。
一个goroutine必定对应一个函数,可以创建多个goroutine去执行相同的函数。

单个goroutine示例

直接上代码:

func hello()  {
    fmt.Println("hello ares")
}
func main()  {  
    hello() 
   fmt.Println("hello main")
}

以上函数输出结果是先输出hello ares,然后输出hello main。
我们启动一个goroutine来执行试一下:

func hello()  {
    fmt.Println("hello ares")
}
func main()  {  
    go hello()  
   fmt.Println("hello main")
}

程序只输出了hello main,并没有输出hello ares。
在程序启动时,Go程序就会为main()函数创建一个默认的goroutine。
当main()函数返回的时候该goroutine就结束了,所有在main()函数中启动的goroutine会一同结束,所以hello()函数的goroutine并没有执行。
想要执行hello()函数,可以让main函数等一等退出:

func hello()  {
    fmt.Println("hello ares")
}
func main()  {  
    go hello()  
   fmt.Println("hello main")
   time.Sleep(time.Second)
}

此时会先打印hello main,然后再打印hello ares。
我们在创建新的goroutine的时候需要花费一些时间,而此时main函数所在的goroutine是继续执行的,所以会先打印hello main。
这种方式虽然可以解决问题,但是并不建议使用,因为sleep会让cpu空跑,浪费资源。
继续优化,我们可以使用sync.WaitGroup来实现goroutine的同步:

var wg sync.WaitGroup
func hello()  {
    fmt.Println("hello ares")
    wg.Done() // hello执行结束,就退出,结束之后通知下wg,让主函数的wg退出,通知wg计数器-1
}
func main()  {
    wg.Add(1)  //计数器+1,开一个协程去干活
    go hello() //开启一个goroutine去执行hello函数
    fmt.Println("hello main")
    wg.Wait()  // 阻塞,等所有协程都干完活后结束,接受done方法,等到计数器为0的时候退出
}

此时,就可以正常输出了。

启动多个goroutine

直接上代码:

var wg sync.WaitGroup
func hello(i int)  {
    fmt.Println("hello ares ",i)
    wg.Done()
}
func main()  {
    for i :=0;i<10;i++{    // 启动10个协程处理
        wg.Add(1)
        go hello(i)
    }
    wg.Wait()
}

会输出hello ares0-9,但是为乱序,因为10个goroutine是并发执行的,而goroutine的调度是随机的。
也可以使用匿名函数实现:

var wg sync.WaitGroup

func main()  {
    for i :=0;i<10;i++{
        wg.Add(1)
        go func(i int) {  // 此处的n是下方传入的i,传入什么就是什么
            fmt.Println("hello ares ",i)
            wg.Done()
        }(i)      //此出的i就是for循环的i
    }
    wg.Wait()
}

与上方效果是一样的。

GOMAXPROCS

Go运行时的调度器使用GOMAXPROCS参数来确定需要使用多少个OS线程来同时执行Go代码。默认值是机器上的CPU核心数。例如在一个8核心的机器上,调度器会把Go代码同时调度到8个OS线程上(GOMAXPROCS是m:n调度中的n)。
Go语言中可以通过runtime.GOMAXPROCS()函数设置当前程序并发时占用的CPU逻辑核心数。
Go1.5版本之前,默认使用的是单核心执行。Go1.5版本之后,默认使用全部的CPU逻辑核心数。
直接上代码:

var wg sync.WaitGroup
func hello01()  {
    for i :=0;i<5;i++{
        fmt.Println("hello01 ",i)
    }
    wg.Done()
}
func hello02()  {
    for i :=0;i<5;i++{
        fmt.Println("hello02 ",i)
    }
    wg.Done()
}

func main()  {
    runtime.GOMAXPROCS(1) //占用一个核心数,所以同时只能由一个goroutine执行,执行完后会另一个才会执行
    wg.Add(2)
    go hello01()
    go hello02()
    wg.Wait()
}

以上代码会依次执行 hello01()或者 hello02()函数,执行完毕后才会执行另一个。
若把runtime.GOMAXPROCS设置成2或者以上,那么执行就没有顺序了。
Go语言中的操作系统线程和goroutine的关系:

  • 一个操作系统线程对应用户态多个goroutine。
  • go程序可以同时使用多个操作系统线程。
  • goroutine和OS线程是多对多的关系,即m:n。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


Golang的文档和社区资源:为什么它可以帮助开发人员快速上手?
Golang:AI 开发者的实用工具
Golang的标准库:为什么它可以大幅度提高开发效率?
Golang的部署和运维:如何将应用程序部署到生产环境中?
高性能AI开发:Golang的优势所在
本篇文章和大家了解一下go语言开发优雅得关闭协程的方法。有一定的参考价值,有需要的朋友可以参考一下,希望对大家有所帮助。1.简介本文将介绍首先为什么需要主...
这篇文章主要介绍了Go关闭goroutine协程的方法,具有一定借鉴价值,需要的朋友可以参考下。下面就和我一起来看看吧。1.简介本文将介绍首先为什么需要主动关闭gor...
本篇文章和大家了解一下go关闭GracefulShutdown服务的几种方法。有一定的参考价值,有需要的朋友可以参考一下,希望对大家有所帮助。目录Shutdown方法Regi...
这篇文章主要介绍了Go语言如何实现LRU算法的核心思想和实现过程,具有一定借鉴价值,需要的朋友可以参考下。下面就和我一起来看看吧。GO实现Redis的LRU例子常
今天小编给大家分享的是Go简单实现多租户数据库隔离的方法,相信很多人都不太了解,为了让大家更加了解,所以给大家总结了以下内容,一起往下看吧。一定会...
这篇“Linux系统中怎么安装NSQ的Go语言客户端”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希
本文小编为大家详细介绍“怎么在Go语言中实现锁机制”,内容详细,步骤清晰,细节处理妥当,希望这篇“怎么在Go语言中实现锁机制”文章能帮助大家解决疑惑,下面...
今天小编给大家分享一下Go语言中interface类型怎么使用的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以分享这篇文章给大家参考
这篇文章主要介绍“怎么以正确的方式替换Go语言程序自身”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希
本文小编为大家详细介绍“Go语言中除法运算的效率怎么提高”,内容详细,步骤清晰,细节处理妥当,希望这篇“Go语言中除法运算的效率怎么提高”文章能帮助大家解...
本文小编为大家详细介绍“Go语言中的next()方法怎么使用”,内容详细,步骤清晰,细节处理妥当,希望这篇“Go语言中的next()方法怎么使用”文章能帮助大家解决疑...
这篇文章主要介绍了Go语言中slice的反转方法怎么使用的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇Go语言中slice的反转方法怎...
这篇文章主要介绍“怎么使用Go语言实现数据转发功能”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“怎么使用Go语
这篇文章主要讲解了“Go语言中怎么实现代码跳转”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究
这篇文章主要讲解了“Go语言如何多开协程”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Go语言如何多开协...