Go语言并发编程:Goroutines和Channels的详细指南

简介: Go语言并发编程:Goroutines和Channels的详细指南
0. 并发和并行的区别

并发与并行在许多情况下被用作相互替代的术语,但在计算中,它们之间有着明显的区别。并发是指同时管理很多事情,这是软件设计的一种方式;而并行执行则指同时做很多事情,是根据硬件的计算能力来进行的。

例如,假设我们在一个餐厅里做若干件事情:点菜、吃饭、结账。在并发的世界里,我们将这些任务分解开,可以同时管理但不一定同时执行。而在并行的世界里,我们实际上在同一时刻做了多件事情,比如我们可以边吃饭边聊天。

1. Goroutines介绍和创建

Goroutines是由Go语言运行时环境管理的轻量型线程。与OS线程或者其他编程语言的线程相比,Goroutines的创建和撤销的成本更低。

当你需要创建一个新的Goroutine时,只需要使用go关键字:

go function()

比如,我们有下面的函数:

func sayHello() {
    fmt.Println("Hello, World")
}

通过在函数调用前添加go关键字,就可以将它变成一个goroutine:

go sayHello()
2. Channels的原理和使用

Channels是用来在Goroutines之间进行通信的数据结构,可以把它们看作是Goroutines之间的管道。你可以通过channel发送和接收数据。

在Go中创建channel的方式如下:

ch := make(chan int)

这里创建了一个整型channel。然后我们可以使用<-运算符向channel发送数值或者从channel读取数值。比如:

ch <- 5 // send 5 to channel ch
x := <- ch // receive from ch, and assign value to x

Goroutine默认是异步操作的,即开启一个新的Goroutine后,不会阻塞当前线程的继续执行。但是有时候我们需要等待一个或者多个Goroutines完成后继续,这时我们可以使用sync.WaitGroup

var wg sync.WaitGroup
wg.Add(1)  // 增加等待的Goroutine数量
go func() {
  defer wg.Done()  // 在Goroutine结束时调用,表示有一个Goroutine已经完成
  // 此处为Goroutine实际执行的代码
} 
wg.Wait()  // 在此处等待所有的Goroutine完成

Channel是Go提供的一种强大的通信机制。我们先前讨论了基本的Channel创建和操作,这次我们来看一下更高级的用法。

  • 有缓冲和无缓冲Channel

创建Channel时,可以为其指定一个缓冲大小。有缓冲的Channel在满载或空载时才会阻塞,反之无缓冲的Channel在每次发送和读取数据时都会阻塞。

ch := make(chan int) // 无缓冲
ch := make(chan int, 5) // 缓冲大小为5

select语句

Go的select关键字让我们可以在channel上做出更复杂的操作。select会监听case语句中channel的读写操作,当channel读写操作为非阻塞状态(即能读写)时执行相对应的语句。select中默认是不带有default的,也就是说如果没有符合的case,select将会阻塞直到有符合的case出现。

select {
    case <-chan1:
       // 如果chan1成功读到数据,则进行该case处理语句
    case chan2 <- 1:
       // 如果成功向chan2写入数据,则进行该case处理语句
    default:
       // 如果上面都没有成功,则进入default处理流程
}
3. Go中的Goroutine如何调度

对于Goroutine的调度,Go选择了成本较低的M:N调度(也称为两级调度)模型。在这种模型中,存在两个调度层:

OS调度层:OS调度层负责在物理线程(内核线程)上调度线程。OS线程的创建、切换和销毁成本都相对较高,而且会消耗大量的系统资源。

Go运行时调度层:Go运行时调度层负责在逻辑执行器(P)上调度Goroutines。相比于OS线程,Goroutines的创建、切换和销毁的成本都非常低。

Go调度器使用了很多技术和策略来使得其Goroutine的调度更加高效,比如工作窃取, 抢占, 系统监控等。Go调度器的目的是让程序能够充分利用所有的CPU资源,让每个CPU都有Goroutine在运行。

4. 和其他编程语言的比较

在许多传统的编程语言中,例如Java和C++,并发模型通常基于线程,这意味着开发人员需要直接与低级别的线程API打交道,包括但不限于线程生命周期的管理,以及复杂的同步原语,如互斥量和条件变量。这种并发模型常常导致代码难以编写和理解。


相比之下,Go的并发模型基于CSP(Communicating Sequential Processes)理论,把并发的复杂性隐藏在语言层面,开发人员无须关心内部的实现细节。Go提供的Goroutines和Channel,使得我们可以用更为简单和直观的方式来编写并发程序。

5. 案例和应用场景

在实际的开发过程中,我们往往需要根据实际需求来选择使用Goroutine, Channel或是互斥锁等工具。例如,如果我们在编写一个网站爬虫,可能会遇到这样的需求:我们需要启动多个Goroutine去分别爬取网站的不同部分,而主Goroutine需要等待所有的爬虫Goroutine都完成任务后才能进行下一步。这种情况下,我们就可以利用WaitGroup来同步多个Goroutine的执行进度。

相关文章
|
9天前
|
存储 监控 算法
员工上网行为监控中的Go语言算法:布隆过滤器的应用
在信息化高速发展的时代,企业上网行为监管至关重要。布隆过滤器作为一种高效、节省空间的概率性数据结构,适用于大规模URL查询与匹配,是实现精准上网行为管理的理想选择。本文探讨了布隆过滤器的原理及其优缺点,并展示了如何使用Go语言实现该算法,以提升企业网络管理效率和安全性。尽管存在误报等局限性,但合理配置下,布隆过滤器为企业提供了经济有效的解决方案。
46 8
员工上网行为监控中的Go语言算法:布隆过滤器的应用
|
29天前
|
Go 开发工具
百炼-千问模型通过openai接口构建assistant 等 go语言
由于阿里百炼平台通义千问大模型没有完善的go语言兼容openapi示例,并且官方答复assistant是不兼容openapi sdk的。 实际使用中发现是能够支持的,所以自己写了一个demo test示例,给大家做一个参考。
|
29天前
|
程序员 Go
go语言中结构体(Struct)
go语言中结构体(Struct)
101 71
|
28天前
|
存储 Go 索引
go语言中的数组(Array)
go语言中的数组(Array)
105 67
|
4天前
|
算法 安全 Go
Go 语言中实现 RSA 加解密、签名验证算法
随着互联网的发展,安全需求日益增长。非对称加密算法RSA成为密码学中的重要代表。本文介绍如何使用Go语言和[forgoer/openssl](https://github.com/forgoer/openssl)库简化RSA加解密操作,包括秘钥生成、加解密及签名验证。该库还支持AES、DES等常用算法,安装简便,代码示例清晰易懂。
32 12
|
7天前
|
监控 算法 安全
解锁企业计算机监控的关键:基于 Go 语言的精准洞察算法
企业计算机监控在数字化浪潮下至关重要,旨在保障信息资产安全与高效运营。利用Go语言的并发编程和系统交互能力,通过进程监控、网络行为分析及应用程序使用记录等手段,实时掌握计算机运行状态。具体实现包括获取进程信息、解析网络数据包、记录应用使用时长等,确保企业信息安全合规,提升工作效率。本文转载自:[VIPShare](https://www.vipshare.com)。
19 0
|
21天前
|
Go 数据安全/隐私保护 UED
优化Go语言中的网络连接:设置代理超时参数
优化Go语言中的网络连接:设置代理超时参数
|
1月前
|
并行计算 安全 Go
Go语言中的并发编程:掌握goroutines和channels####
本文深入探讨了Go语言中并发编程的核心概念——goroutine和channel。不同于传统的线程模型,Go通过轻量级的goroutine和通信机制channel,实现了高效的并发处理。我们将从基础概念开始,逐步深入到实际应用案例,揭示如何在Go语言中优雅地实现并发控制和数据同步。 ####
|
2月前
|
存储 Go 开发者
Go语言中的并发编程与通道(Channel)的深度探索
本文旨在深入探讨Go语言中并发编程的核心概念和实践,特别是通道(Channel)的使用。通过分析Goroutines和Channels的基本工作原理,我们将了解如何在Go语言中高效地实现并行任务处理。本文不仅介绍了基础语法和用法,还深入讨论了高级特性如缓冲通道、选择性接收以及超时控制等,旨在为读者提供一个全面的并发编程视角。
|
2月前
|
安全 Serverless Go
Go语言中的并发编程:深入理解与实践####
本文旨在为读者提供一个关于Go语言并发编程的全面指南。我们将从并发的基本概念讲起,逐步深入到Go语言特有的goroutine和channel机制,探讨它们如何简化多线程编程的复杂性。通过实例演示和代码分析,本文将揭示Go语言在处理并发任务时的优势,以及如何在实际项目中高效利用这些特性来提升性能和响应速度。无论你是Go语言的初学者还是有一定经验的开发者,本文都将为你提供有价值的见解和实用的技巧。 ####