Go 语言入门很简单:从 goroutine 出发到并发

简介: goroutine 是 Go 中最基本的组织单位之一,是 Go 支持原生并发最重要的一个功能。事实上,每个 Go 程序至少拥有一个:main gotoutine ,当程序开始时会自动创建并启动。简单来说,gotoutine 是一个并发的函数(记住:不一定是并行)和其他代码一起运行。

goroutine

goroutine 是 Go 中最基本的组织单位之一,是 Go 支持原生并发最重要的一个功能。


事实上,每个 Go 程序至少拥有一个:main gotoutine ,当程序开始时会自动创建并启动。


简单来说,gotoutine 是一个并发的函数(记住:不一定是并行)和其他代码一起运行。


并发和并行的区别:并行机制指某个类型的多个实体同步执行,而并发是一种构建组件的方法,并在必要时能够独立地执行这些组件。


你可以简单的通过将 go 关键字放在函数前面来启动它:

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


对于匿名函数,同样也能这么干,从下面这个例子你可以看得很明白。在下面的例子中,我们不是从一个函数建立一个 goroutine ,而是从一个匿名函数创建一个 goroutine :

go func() {
fmt.Println("hello")
}()// 1
// continue doing other things
//注意这里的(),我们必须立刻调用匿名函数来使go关键字有效。或者,你可以将函数分配给一个变量,并像这样调用它:
sayHello := func() {
  fmt.Println("hello")
}
go sayHello()
// continue doing other things


看起来很简单,对吧。我们可以用一个函数和一个关键字创建一个并发逻辑块,这就是启动 goroutine 所需要知道的全部。当然,关于如何正确使用它,对它进行同步以及如何组织它还有很多需要说明的内容。

goroutine 及它是如何工作的

本节将回答下面三个问题:goroutine 实际上是如何工作的? goroutine 是操作系统线程吗?还是说 goroutine 是绿色线程吗?我们可以创建多少个 goroutine 呢?


goroutines 对 Go 来说是独一无二的(尽管其他一些语言有类似的并发原语)。它们不是操作系统线程,它们不完全是绿色的线程(由语言运行时管理的线程),它们是更高级别的抽象,被称为协程(coroutines)。协程是非抢占的并发子程序,也就是说,它们不能被中断。


Go 的独特之处在于 goutine 与 Go 的运行时深度整合。Goroutine 没有定义自己的暂停或再入点; Go 语言在运行时观察着 goroutine 的行为,并在阻塞时自动挂起它们,然后在它们变畅通时恢复它们。在某种程度上,这使得它们可以抢占,但只是在 goroutine 被阻止的地方。它是运行时和 goroutine 逻辑之间的一种优雅合作关系。 因此,goroutine 可以被认为是一种特殊的协程。

什么是协程

协程,可以被认为是轻量级的线程。与线程不同的是,操作系统内核感知不到协程的存在。


协程的管理依赖 Go 语言运行时自身提供的调度器。也可以被认为是 goroutine 的隐式并发构造,但并发并非协程自带的属性:调度器必须能够同时托管几个协程,并给每个协程执行的机会,否则它们无法实现并发。当然,有可能有几个协程按顺序执行,但看起来就像并行一样。


协程是用户态的,Go 语言的协程从属于某个线程。Go 调度器通过多路复用技术,实现了所谓的 M:N 调度器,这意味着它将 M 个协程映射到 N 个系统线程。Go 调度器表示为负责 Go 程序中协程的执行方式和顺序的 Go 组件,Go 程序中的一切事物都将作为一个协程而执行。

创建一个协程

通过常规函数和匿名函数可以创建一个 goroutine,如新建一个 main.go 文件,写入如下代码:

package main
import (
  "fmt"
  "time"
)
func printNum() {
  for i := 0; i < 10; i++ {
    fmt.Print(i)
  }
}
func main() {
  go printNum()  // 常规函数创建协程
  // 匿名函数闯将协程
  go func() {
    for i := 10; i < 20; i++ {
      fmt.Print(i, " ")
    }
  }()
  time.Sleep(1 * time.Second)
  fmt.Println()
}

运行该代码,可能每次得到的结果还不一眼:

[Running] go run "/Users/yuzhou_1su/GoProjects/Go 并发/v1/main.go"
010 11 12 13 14 15 16 17 18 19 123456789
[Running] go run "/Users/yuzhou_1su/GoProjects/Go 并发/v1/main.go"
01210 11 12 13 14 15 16 17 18 19 3456789


每次运行结果不同说明了如果缺少额外对协程的操作,就无法控制协程的执行顺序。

创建多个协程

通过 flag 读取命令行动态数量的协程,比如通过 flag.Int 来读取命令行选项值,进而确定要创建的协程的数量。如果不传入值,n 的值将会变成 10.


利用 for 循环生成所需的协程数量,协程运行时很快的,只有通过 time.sleep() 语句赋予线程足够的时间结束其任务,以便我们能在命令行输出最终结果。如果不使用这条语句,可能会看不到完整的结果,读者可以自己试试。

package main
import (
  "flag"
  "fmt"
  "time"
)
func main() {
  n := flag.Int("num", 10, "Number of goroutines")
  flag.Parse()
  count := *n
  fmt.Printf("Going to create %d goroutine.\n", count)
  for i := 0; i < count; i++ {
    go func(x int) {
      fmt.Printf("%d ", x)
    }(i)
  }
  time.Sleep(time.Second)
  fmt.Println("\nExiting...")
}


运行该代码:

$ go run main.go -num 100
Going to create 100 goroutine.
5 3 4 0 29 17 18 19 16 6 7 8 9 10 11 12 13 14 15 20 1 22 21 44 55 30 32 33 34 35 36 37 38 39 2 23 41 27 24 52 26 47 31 42 25 28 43 40 70 54 45 46 66 67 56 60 68 62 59 72 76 78 58 82 83 50 80 91 96 61 90 98 77 87 49 73 74 53 79 75 65 48 84 63 94 71 51 92 64 93 89 85 97 69 88 86 57 99 95 81 
Exiting...
$ go run main.go -num 100
Going to create 100 goroutine.
13 7 8 9 10 11 12 0 1 36 14 15 16 17 18 19 20 3 6 4 5 28 22 23 24 21 27 30 31 33 29 2 34 48 25 57 35 37 49 50 51 52 53 54 55 56 42 39 38 32 44 40 74 89 58 75 87 47 60 94 26 64 41 92 85 67 81 46 43 88 83 77 80 90 63 91 84 96 59 65 99 66 86 93 79 76 61 98 68 69 82 45 78 72 70 71 62 73 95 97 
Exiting...

总结

goroutine 是 Go 语言中的轻量级线程实现,也即协程,由 Go 调度器在运行时管理,有两种方式创建 goroutine,一种是直接在常规函数前加上关键字 go,或者声明一个匿名函数。


运行时被 go 声明的 goroutine 会在新的 goroutine 中并发执行,当被调用的函数返回时,这个 goroutine 也就自动结束了。


值得注意的是,多个协程一般没有先后顺序,只有通过一定得方式(比如通道、锁等)来限定顺序。


在学习过程中,我们会利用 time.Sleep 来等待协程运行完输出,实际上并不需要时间的延迟。


最后,学习会 goroutine 只是学习 Go 并发的第一步,后续还有更多的并发知识点等着我们去探索,下一篇文章见!

相关文章
|
16天前
|
存储 Go 索引
go语言中数组和切片
go语言中数组和切片
26 7
|
16天前
|
Go 开发工具
百炼-千问模型通过openai接口构建assistant 等 go语言
由于阿里百炼平台通义千问大模型没有完善的go语言兼容openapi示例,并且官方答复assistant是不兼容openapi sdk的。 实际使用中发现是能够支持的,所以自己写了一个demo test示例,给大家做一个参考。
|
16天前
|
程序员 Go
go语言中结构体(Struct)
go语言中结构体(Struct)
92 71
|
15天前
|
存储 Go 索引
go语言中的数组(Array)
go语言中的数组(Array)
100 67
|
18天前
|
Go 索引
go语言for遍历数组或切片
go语言for遍历数组或切片
88 62
|
20天前
|
并行计算 安全 Go
Go语言中的并发编程:掌握goroutines和channels####
本文深入探讨了Go语言中并发编程的核心概念——goroutine和channel。不同于传统的线程模型,Go通过轻量级的goroutine和通信机制channel,实现了高效的并发处理。我们将从基础概念开始,逐步深入到实际应用案例,揭示如何在Go语言中优雅地实现并发控制和数据同步。 ####
|
16天前
|
存储 Go
go语言中映射
go语言中映射
32 11
|
18天前
|
Go
go语言for遍历映射(map)
go语言for遍历映射(map)
29 12
|
17天前
|
Go 索引
go语言使用索引遍历
go语言使用索引遍历
26 9
|
21天前
|
安全 Serverless Go
Go语言中的并发编程:深入理解与实践####
本文旨在为读者提供一个关于Go语言并发编程的全面指南。我们将从并发的基本概念讲起,逐步深入到Go语言特有的goroutine和channel机制,探讨它们如何简化多线程编程的复杂性。通过实例演示和代码分析,本文将揭示Go语言在处理并发任务时的优势,以及如何在实际项目中高效利用这些特性来提升性能和响应速度。无论你是Go语言的初学者还是有一定经验的开发者,本文都将为你提供有价值的见解和实用的技巧。 ####