Go 语言学习之 goroutine 和 channel

简介: Go 语言学习之 goroutine 和 channel

01

goroutine


当一个 go 程序运行时,调用 main 函数入口的 goroutine 是主 goroutine,我们还可以使用关键字 go 创建新的 goroutine。在 Go 语言中,创建 goroutine 的语法很简单,只需要在函数或方法调用前加上 go 关键字。


02

channel


channel 是可以让一个 goroutine 发送特定的值到另一个 goroutine 的通信机制。Go 官方鼓励使用 CSP 并发编程风格,以通信代替内存共享,实现并发安全。


与 map 类似,channel 也是使用内置函数 make 创建。channel 是引用类型,它的零值是 nil,channel 可以和 nil 进行比较,相同类型的 channel 可以使用 “==” 符号进行比较。


使用内置函数 make 创建 channel 时,有两个参数,第一个参数是元素类型,第二个可选参数是 channel 的容量。不设置 channel 容量称为无缓冲 channel,设置 channel 容量称为缓冲 channel。无缓冲 channel 是一种阻塞的同步 channel。内置函数 cap 可以获取缓冲 channel 的容量,内置函数 len 可以获取缓冲 channel 的元素个数。


03

channel 操作


channel 操作有三种,分别是 send、receive 和 close。send 操作可以从一个执行的 goroutine 传输一个值到另一个执行 receive 操作的 goroutine。


send 操作和 receive 操作都使用 “<-” 操作符,在 send 语句中,channel 和值分别在操作符左右两边,在 receive 语句中,操作符放在 channel 操作数的前面。


close 操作通过设置一个标志位来表示当前值已经 send 完毕,channel 不会再被 send 值了,close 操作后的 send 操作将导致宕机。在一个已经执行 close 操作的 channel 上执行 receive 操作,将获取这个 channel 上所有已经 send 的值,直到 channel 为空。


缓冲 channel 的 send 操作在队列的尾部插入一个元素,receive 操作在队列的头部移除一个元素。如果缓冲 channel 容量占满,send 操作会阻塞所在的 goroutine,直到另一个 goroutine 对它执行 receive 操作来腾出可用空间。如果缓冲 channel 是空的,receive 操作的 goroutine 阻塞,直到另一个 goroutine 在这个缓冲 channel 上 send 数据。


需要注意的是,如果在同一个缓冲 channel 上执行 send 操作和 receive 操作,是将缓冲 channel 错误地作为队列使用了。在实际项目开发中,send 操作和 receive 操作是由不同的 goroutine 执行的。


无缓冲 channel 的每一次 send 操作都对应一次 receive 操作,实现强同步。缓冲 channel 的 send 操作和 receive 操作是解耦的。我们如果事先可以知道需要 send 的值的数量上限,可以创建一个容量是使用上限的缓冲 channel,在 receive 第一个值前就完成了所有的 send 操作。


使用缓冲 channel,需要注意 send 操作和 receive 操作的 goroutine 的执行效率,否则会影响性能。


04

select 多路复用


select 语句类似 switch 语句,有至少一个 case 分支,和一个可选的默认分支 default。每一个 case 分支指定一次通信(在一些 channel 上执行 send 操作或 receive 操作)和关联的一段代码块。


select 一直处于等待状态,直到一次通信可以符合条件执行某一个或多个 case 分支的代码块,然后 select 执行这次通信,并执行对应的 case 分支,其他的通信将不会发生,select 如果没有可以符合条件执行的 case 分支,它将永远处于等待状态。select 如果同时符合多个 case 分支执行,select 将随机选择一个 case 分支执行。


select  如果有可选默认分支 default,在没有通信可以符合条件执行某一个 case 分支时,它将执行默认分支 default 的代码块。





目录
相关文章
|
7天前
|
Go
go之channel关闭与广播
go之channel关闭与广播
8 0
|
7天前
|
Go
go语言map、实现set
go语言map、实现set
13 0
|
1天前
|
存储 Go API
一个go语言编码的例子
【7月更文挑战第2天】本文介绍Go语言使用Unicode字符集和UTF-8编码。Go中,`unicode/utf8`包处理编码转换,如`EncodeRune`和`DecodeRune`。`golang.org/x/text`库支持更多编码转换,如GBK到UTF-8。编码规则覆盖7位至21位的不同长度码点。
62 1
一个go语言编码的例子
|
4天前
|
JSON 算法 测试技术
在go语言中调试程序
【6月更文挑战第29天】Go语言内置`testing`包支持单元测试、基准测试和模糊测试。`go test`命令可执行测试,如`-run`选择特定测试,`-bench`运行基准测试,`-fuzz`进行模糊测试。
16 2
在go语言中调试程序
|
2天前
|
安全 Go
Go语言的iota关键字有什么用途?
**Go语言中的`iota`是常量生成器,用于在`const`声明中创建递增的常量。`iota`在每个新的`const`块重置为0,然后逐行递增,简化了枚举类型或常量序列的定义。例如,定义星期枚举:** ```markdown ```go type Weekday int const ( Sunday Weekday = iota // 0 Monday // 1 Tuesday // 2 ... ) ``` 同样,`iota`可用于定义不同组的常量,如状态码和标志位,保持各自组内的递增,提高代码可读性。
|
6天前
|
Devops Go 云计算
Go语言发展现状:历史、应用、优势与挑战
Go语言发展现状:历史、应用、优势与挑战
|
2天前
|
IDE Linux Go
记录一个go语言与IDE之间的问题
【7月更文挑战第1天】本文介绍在IDE中调试Go应用可能遇到的问题。当问题与IDE的自动完成有关,可以试着使用其他编辑器如Linux的vim是否无此问题。这可以验证表明IDE可能不完全兼容最新语言版本,建议使用无自动检测工具临时解决。
17 0
|
5天前
|
编译器 Go C++
必知的技术知识:go语言快速入门教程
必知的技术知识:go语言快速入门教程
|
6天前
|
编译器 Go 开发者
|
7天前
|
Go
go之channel任意任务完成、全部任务完成退出
go之channel任意任务完成、全部任务完成退出
8 0