Go语言探索 - 12(结局)

简介: Go语言基础系列博客用到的所有示例代码上一篇文章文章主要学习了Go语言中的接口、反射以及错误和异常处理。本篇文章主要学习Go语言的协程,当然也是GO语言基础的最后一篇。

Go语言基础系列博客用到的所有示例代码

上一篇文章文章主要学习了Go语言中的接口、反射以及错误和异常处理。本篇文章主要学习Go语言的协程,当然也是GO语言基础的最后一篇。

goroutine:

goroutine是Go并行设计的核心,也是这门语言的精髓体现。goroutine这个关键字就是协程,但是它比线程更小。说起线程,大家可能都不陌生。线程,是程序执行的最小单元。一个标准的线程由线程ID,当前指令指针,寄存器集合和堆栈组成。另外,线程是进程中的一个实体,是被系统独立调度和分派的基本单位,线程自己不拥有系统资源,只拥有一点儿在运行中必不可少的资源,但它可与同属一个进程的其它线程共享进程所拥有的全部资源。

现在Go语言运用协程这一比线程更小的执行单元,十几个goroutine可能体现在底层就是五六个线程,Go语言内部帮你实现了这些goroutine之间的内存共享。执行goroutine只需极少的栈内存(大概是4~5KB),当然会根据相应的数据伸缩。也正因为如此,可同时运行成千上万个并发任务。goroutine比thread更易用、更高效、更轻便。

goroutine是通过Go的runtime管理的一个线程管理器。goroutine的作用就是一个普通的函数。以下是协程的写法以及结果测试:

img_65dc54f0b6bb2920ce559b04e7d30d78.png
测试 - 1


img_783d0501c44b53cc0d1ea8241a0a1d9b.png
测试 - 2


img_c510b9d3d0c41c4a09e76db35898c656.png
测试 - 3

理论上来说:多个goroutine运行在同一个进程里面,共享内存数据,不过设计上我们要遵循:不要通过共享来通信,而要通过通信来共享。goroutine运行在相同的地址空间,因此访问共享内存必须做好同步。那么goroutine之间如何进行数据的通信呢,Go提供了一个很好的通信机制:channel。

channel是Go中的一个核心类型,你可以把它看成一个管道,通过它并发核心单元就可以发送或者接收数据进行通讯。

首先,channel必须先创建再使用,另外它的操作符是箭头 <-

Channel类型的定义格式(有三种写法)如下:

ChannelType = ( "chan" | "chan" "<-" | "<-" "chan" ) 数据类型

其中,这里的 <- 代表的是channel方向。如果没有指定方向,那么Channel就是双向,这样就意味可以接收数据,也可以发送数据。

(前面说了可以把channel看成一个管道,既然是管道那么就有流向)。也就是下面三种写法:

chan T          // 可以接收和发送类型为 T 的数据

chan<- float64  // 只可以用来发送 float64 类型的数据

<-chan int      // 只可以用来接收 int 类型的数据

另外:

<-总是优先和最左边的类型结合。以下是几种组合写法:

chan<- chan int    // 等价 chan<- (chan int)

chan<- <-chan int  // 等价 chan<- (<-chan int)

<-chan <-chan int  // 等价 <-chan (<-chan int)

容量(capacity):

使用make也可以初始化Channel,并且可以设置channel的容量:

这里的容量可以这样理解,就是channel可以存储多少个元素,指定channel的缓冲大小、另外一个nil channel不会通信。

写法:

ch := make(chan type, value)

当 value = 0 时,也就说明channel 是无缓冲阻塞读写的;

当 value > 0 时,channel 有缓冲、是非阻塞的,直到写满 value 个元素才阻塞写入。例如:

img_12acf6e41504e7908d12f3b66b922073.png
容量

以上代码不变,当我们把容量设置为1,就会出现如下问题:

img_9ce33702b757af34997359ffd4e14f5a.png
容量不足

Range和Close

range,这个关键字可以像操作slice或者map一样,去操作缓存类型的channel;

close,这个关键字主要是用来关闭channel。关闭channel之后就无法再发送任何数据。


img_c69e28ae8295100708f76fafa736f7ee.png
rang

上面的代码都是只有一个channel的情况,那么如果存在多个channel的时候,我们该如何操作呢?

Go里面提供了一个关键字select,通过select可以监听channel上的数据流动。

它类似switch,但是只是用来处理通讯(communication)操作。它的case可以是send语句(发送),也可以是receive语句(接收),亦或者default。

default就是当监听的channel都没有准备好的时候,默认执行

select默认是阻塞的,只有当监听的channel中有发送或接收可以进行时才会运行,当多个channel都准备好的时候,select是随机的选择一个执行的。

代码如下:

func main() {

c := make(chan int)

quit := make(chan int)

go func() {

for i := 0; i < 3; i++ {

fmt.Println("<-c == ",<-c)

}

quit <- 0

}()

testSelect(c, quit)

}

func testSelect(c, quit chan int) {

x, y := 1, 1

for {

select {

case c <- x:

x, y = y, x + y

fmt.Println("x == ",x)

fmt.Println("y+x == ",y+x)

case <- quit:

fmt.Println("quit")

return

}

}

}

超时处理:timeout

select有很重要的一个应用就是超时处理。如果select中没有case需要处理,select语句就会一直阻塞着。

这时候我们可能就需要一个超时操作,用来处理超时以避免整个程序进入阻塞。Go语言的超时处理是使用的timeout关键字

以下是复现超时的例子,我分了两种情况:

img_e1b7ae205421dff145500b329f17f5b1.png

下面是第二种,复现超时的情景:

img_6b61eed7560e530c9be9b613ead6d296.png
复现超时

下面是收集了一些runtime包中关于处理goroutine的几个函数:

A: Goexit 这个函数的意思指:退出当前执行的goroutine,但是defer函数还会继续调用

B: Gosched 这个函数的意思指:让出当前goroutine的执行权限,调度器安排其他等待的任务运行,并在下次某个时候从该位置恢复执行。

C: NumCPU 这个函数的意思指:返回 CPU 核数量

D: NumGoroutine 这个函数的意思指:返回正在执行和排队的任务总数

E: GOMAXPROCS 这个函数的意思指:用来设置可以并行计算的CPU核数的最大值,并返回之前的值。


结语:

关于Go语言的基础内容,基本上就写完了。也算是这一阶段的学习笔记与总结。

GoLang在学习的过程中,个人最深刻的体会就是对内存的超严格控制管理、语法简洁精悍、更小更精准的协程执行单元、函数多返回值等等特点。

虽然网上对这么语言褒贬不一,但还是希望这门语言可以发展的越来越好。

如果这篇文章对你有帮助,希望各位看官留下宝贵的star,谢谢。

Ps:著作权归作者所有,转载请注明作者, 商业转载请联系作者获得授权,非商业转载请注明出处(开头或结尾请添加转载出处,添加原文url地址),文章请勿滥用,也希望大家尊重笔者的劳动成果

相关文章
|
13天前
|
存储 JSON 监控
Viper,一个Go语言配置管理神器!
Viper 是一个功能强大的 Go 语言配置管理库,支持从多种来源读取配置,包括文件、环境变量、远程配置中心等。本文详细介绍了 Viper 的核心特性和使用方法,包括从本地 YAML 文件和 Consul 远程配置中心读取配置的示例。Viper 的多来源配置、动态配置和轻松集成特性使其成为管理复杂应用配置的理想选择。
33 2
|
11天前
|
Go 索引
go语言中的循环语句
【11月更文挑战第4天】
21 2
|
11天前
|
Go C++
go语言中的条件语句
【11月更文挑战第4天】
24 2
|
15天前
|
程序员 Go
go语言中的控制结构
【11月更文挑战第3天】
90 58
|
1天前
|
Go 调度 开发者
Go语言中的并发编程:深入理解goroutines和channels####
本文旨在探讨Go语言中并发编程的核心概念——goroutines和channels。通过分析它们的工作原理、使用场景以及最佳实践,帮助开发者更好地理解和运用这两种强大的工具来构建高效、可扩展的应用程序。文章还将涵盖一些常见的陷阱和解决方案,以确保在实际应用中能够避免潜在的问题。 ####
|
1天前
|
测试技术 Go 索引
go语言使用 range 关键字遍历
go语言使用 range 关键字遍历
12 3
|
1天前
|
测试技术 Go 索引
go语言通过 for 循环遍历
go语言通过 for 循环遍历
10 3
|
3天前
|
安全 Go 数据处理
Go语言中的并发编程:掌握goroutine和channel的艺术####
本文深入探讨了Go语言在并发编程领域的核心概念——goroutine与channel。不同于传统的单线程执行模式,Go通过轻量级的goroutine实现了高效的并发处理,而channel作为goroutines之间通信的桥梁,确保了数据传递的安全性与高效性。文章首先简述了goroutine的基本特性及其创建方法,随后详细解析了channel的类型、操作以及它们如何协同工作以构建健壮的并发应用。此外,还介绍了select语句在多路复用中的应用,以及如何利用WaitGroup等待一组goroutine完成。最后,通过一个实际案例展示了如何在Go中设计并实现一个简单的并发程序,旨在帮助读者理解并掌
|
2天前
|
Go 索引
go语言按字符(Rune)遍历
go语言按字符(Rune)遍历
12 3
|
6天前
|
Go API 数据库
Go 语言中常用的 ORM 框架,如 GORM、XORM 和 BeeORM,分析了它们的特点、优势及不足,并从功能特性、性能表现、易用性和社区活跃度等方面进行了比较,旨在帮助开发者根据项目需求选择合适的 ORM 框架。
本文介绍了 Go 语言中常用的 ORM 框架,如 GORM、XORM 和 BeeORM,分析了它们的特点、优势及不足,并从功能特性、性能表现、易用性和社区活跃度等方面进行了比较,旨在帮助开发者根据项目需求选择合适的 ORM 框架。
26 4