GO学习之 协程(goroutine)_go 协程-程序员宅基地

技术标签: golang  golang学习  

GO系列

1、GO学习之Hello World
2、GO学习之入门语法
3、GO学习之切片操作
4、GO学习之 Map 操作
5、GO学习之 结构体 操作
6、GO学习之 通道(Channel)
7、GO学习之 多线程(goroutine)
8、GO学习之 函数(Function)
9、GO学习之 接口(Interface)
10、GO学习之 网络通信(Net/Http)
11、GO学习之 微框架(Gin)
12、GO学习之 数据库(mysql)
13、GO学习之 数据库(Redis)
14、GO学习之 搜索引擎(ElasticSearch)
15、GO学习之 消息队列(Kafka)
16、GO学习之 远程过程调用(RPC)
17、GO学习之 goroutine的调度原理
18、GO学习之 通道(nil Channel妙用)
19、GO学习之 同步操作sync包
20、GO学习之 互斥锁、读写锁该如何取舍
21、GO学习之 条件变量 sync.Cond
22、GO学习之 单例模式 sync.Once
23、GO 面试题总结一【面试官这样问】

前言

按照公司目前的任务,go 学习是必经之路了,虽然行业卷,不过技多不压身,依旧努力!!!
在 通道 篇中已学习了 goroutine 之间是怎么实现信息互换的,有了这个基础,那现在就来学习一下 Go 自带的天生丽质的 goroutine。

一、并发介绍

1.1 进程和线程和协程

  • 进程(Process):
  • 进程是系统级别的,是操作系统中的一个实例。
  • 每个进程都有自己的内存空间和系统资源,进程之间数据通信和数据交换需要使用进程间通信(IPC)机制。
  • 进程是操作系统分配资源的最小单位,每个程序都可以由多个进程同时执行,每个进程都在独立的地址空间执行。
  • 所以进程间是隔离开的,一个进程的崩溃不会影响其他进程。
  • 进程的切换开销较大,因为需要切换不同的内存空间和资源。
  • 线程(Thread):
  • 线程进程的一个执行单元,一个进程有多个线程。
  • 同一个进程内的多个线程共享相同的内存空间和系统资源,因此线程间通信更加方便。
  • 线程是操作系统调度的最小单位,同一个进程的多个线程可以在同一地址空间执行。
  • 多个线程之间共享进程的资源,因此一个线程崩溃可能会导致整个进程的崩溃。
  • 线程切换开销较小,因为不涉及地址空间和资源的切换。
  • 协程(Coroutine)
  • 协程是一种用户级的轻量线程,它由程序员控制调度,而不是操作系统。
  • 协程可以看作是一种特殊的线程,但不同于操作系统线程,它是在用户空间进行调度,不需要操作系统上下文进行切换。
  • 协程之间的切换由程序员自己决定,因此可减少线程切换的开销,提高程序的并发性。
  • 协程通常需要配合多线程一起使用,一个线程中可以包含多个协程,线程之间也可以创建协程。
  • Go 语言中,协程(goroutine)的调度是有 Go 运行时(runtime)进行管理的,而不是操作系统调度。这意味着Go 中协程的创建、销毁、切换等操作都是有Go语言运行时库自己管理,而不需要操作系统的线程调度机制。

1.2 并发和并行

  • 多个线程在一个核的CPU上运行,就是并发。
    并发
  • 多个线程在多个CPU上运行,就是并行。
    并行

二、goroutine介绍

  • 在 Go 语言中,goroutine 是一种非常轻量的执行单元,有 Go 运行是(runtime)进行调度,不是有固定大小的线程来处理的。与传统线程相比,goroutine的创建和切换开销很小,因此可以创建大量的 goroutine 来并行执行任务,而不会造成太大的系统负担。
  • goroutine 更像是一种高效的协程,它在并发编程中提供了轻量且较高的方式来处理并发,而不需要显式地创建和管理线程池。
  • 在 Go 语言中,用关键词 go 来创建一个 goruntine,例如:go funName()。
  • goroutine 通过通信来实现共享内存,不是共享内存来实现通信,这个在 channel 篇中讲到。
  • goroutine 的栈在生命周期开始时只有很小的 2KB(经典情况下),当然 goroutine的栈不是固定的,是动态增大或缩小的,所以在 Go 语言中,一次创建 10万 的 goroutine 也是可以的。

三、goroutine操作

3.1 超简单的函数调用

package main

import "fmt"

func main() {
    
	fmt.Println("main函数执行!")
	run(0)
	fmt.Println("main函数执行结束!")
}

func run(i int) {
    
	fmt.Printf("当前第 %+v 个线程执行!\n", i)
}

执行结果:

PS D:\workspaceGo> go run routineTest.go
main函数执行!
当前第 0 个线程执行!
main函数执行结束!

从执行结果上看出,显示有main函数执行!,接着是== run() 函数执行,最后是 main函数执行结束!,看来 main函数 调用了自定义的 run() ==函数。

3.2 go 关键字调用为啥没执行?

下面这段代码和 3.1 中的代码基本一样,只不过是在 ==run()==函数前加了 go 关键词,单独一个协程来执行 ==run()==函数。

package main

import "fmt"

func main() {
    
	fmt.Println("main函数执行!")
	go run(0)
	fmt.Println("main函数执行结束!")
}

func run(i int) {
    
	fmt.Printf("当前第 %+v 个线程执行!\n", i)
}

运行结果:

PS D:\workspaceGo> go run routineTest.go
main函数执行!
main函数执行结束!

发现 run() 函数没有被调用?这是为什么呢?
这是因为,在程序启动时,Go 就为 main() 函数创建了一个默认的 goroutine,当 main() 函数执行结束是,所有在 main() 函数中通过 go 启动的 goroutine 就会一同结束。

main() 函数就像权游里面的 夜王,夜王活着,其他的小异鬼都欢蹦乱跳精神的很,啥都挡不了,但是一旦夜王挂了,那夜王所转化的那些异鬼们也就嗝屁了。

3.3 go 关键字调用成了

下面的例子用,我们用 time.Sleep(time.Second) 让 main() 函数打个盹,不要执行那么快。

package main

import (
	"fmt"
	"time"
)

func main() {
    
	fmt.Println("main函数执行!")
	go run(0)
	fmt.Println("main函数打个盹")
	time.Sleep(time.Second)
	fmt.Println("main函数执行结束!")
}

func run(i int) {
    
	fmt.Printf("当前第 %+v 个线程执行!\n", i)
}

运行结果:

PS D:\workspaceGo> go run routineTest.go
main函数执行!
main函数打个盹
当前第 0 个线程执行!
main函数执行结束!

从执行结果中可以看出,run() 函数执行了,不过在 main() 函数打了个盹之后。

3.3 多个 go 一起 go

如果让多个 go 启动多个 协程,究竟会如何呢?

下面示例用 sync.WaitGroup 来实现 goroutine的同步。

package main

import (
	"fmt"
	"sync"
)

var wg sync.WaitGroup

func main() {
    
	fmt.Println("main函数执行!")
	for i := 0; i < 10; i++ {
    
		// 启动一个 goroutine 就登记 +1
		wg.Add(1)
		go run(i)
	}
	wg.Wait()
	fmt.Println("main函数执行结束!")
}

func run(i int) {
    
	// gotoutine结束就登记 -1
	defer wg.Done()
	fmt.Printf("当前第 %+v 个线程执行!\n", i)
}

运行结果:

PS D:\workspaceGo> go run routineTest.go
main函数执行!
当前第 9 个线程执行!
当前第 3 个线程执行!
当前第 0 个线程执行!
当前第 1 个线程执行!
当前第 2 个线程执行!
当前第 6 个线程执行!
当前第 4 个线程执行!
当前第 5 个线程执行!
当前第 7 个线程执行!
当前第 8 个线程执行!
main函数执行结束!

会发现每次运行,这 10 个 goroutine 执行顺序不一致。这是因为 10 个 goroutine是并发的,而 goroutine 的调度是随机的。

3.4 main goroutine结束了,其他 goroutine呢?

如果主协程退出了,那其他协程还会执行吗?

下面例子中,首先用 go 关键字启动一个匿名函数执行,然后才是 main() 函数执行,循环两次则退出,此时其他的 goroutine 则会随之而消失。

package main

import (
	"fmt"
	"time"
)

func main() {
    
	go func() {
    
		i := 0
		for {
    
			i++
			fmt.Printf("custom goroutinr: %+v\n", i)
			time.Sleep(time.Second)
		}
	}()
	i := 0
	for {
    
		i++
		fmt.Printf(" main goroutine: %+v\n", i)
		time.Sleep(time.Second)
		if i == 2 {
    
			break
		}
	}
}

执行结果:

PS D:\workspaceGo> go run routineTest2.go
 main goroutine: 1
custom goroutinr: 1
custom goroutinr: 2
 main goroutine: 2

从执行结果上可以看处,main goroutine 遍历了两次退出时,其他还的 goroutine 也消失了。

四、总结

到这里 goroutine 基本就有了了解了,在工作中运行方能理解的更透彻。
goroutine 是一种特殊的线程,是由 Go 运行时进行调度管理的,每个 goroutine 只需要最少只需要 几KB空间,创建、切换、销毁基本对系统消耗少之又少,goroutine 奉行通信实现内存共享,而不是共享内存实现数据通信,使用 Channel 来实现协程之间的通信。
goroutine 使用方便,通过一个 go 关键字就可以启动执行一个 goroutine,通过 main() 函数创建的 goroutine 依附于 main goroutine,main()函数结束,其他 goroutine 也会随之而结束,所以在开发中我们还要结束其他手段来高效运用。

现阶段还是对 Go 语言的学习阶段,想必有一些地方考虑的不全面,本文示例全部是亲自手敲代码并且执行通过。
如有问题,还请指教。
评论去告诉我哦!!!一起学习一起进步!!!

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qq_19283249/article/details/132019770

智能推荐

FX3/CX3 JLINK 调试_ezusbsuite_qsg.pdf-程序员宅基地

文章浏览阅读2.1k次。FX3 JLINK调试是一个有些麻烦的事情,经常有些莫名其妙的问题。 设置参见 c:\Program Files (x86)\Cypress\EZ-USB FX3 SDK\1.3\doc\firmware 下的 EzUsbSuite_UG.pdf 文档。 常见问题: 1.装了多个版本的jlink,使用了未注册或不适当的版本 选择一个正确的版本。JLinkARM_V408l,JLinkA_ezusbsuite_qsg.pdf

用openGL+QT简单实现二进制stl文件读取显示并通过鼠标旋转缩放_qopengl如何鼠标控制旋转-程序员宅基地

文章浏览阅读2.6k次。** 本文仅通过用openGL+QT简单实现二进制stl文件读取显示并通过鼠标旋转缩放, 是比较入门的级别,由于个人能力有限,新手级别,所以未能施加光影灯光等操作, 未能让显示的stl文件更加真实。****效果图:**1. main.cpp```cpp#include "widget.h"#include <QApplication>int main(int argc, char *argv[]){ QApplication a(argc, argv); _qopengl如何鼠标控制旋转

刘焕勇&王昊奋|ChatGPT对知识图谱的影响讨论实录-程序员宅基地

文章浏览阅读943次,点赞22次,收藏19次。以大规模预训练语言模型为基础的chatgpt成功出圈,在近几日已经给人工智能板块带来了多次涨停,这足够说明这一风口的到来。而作为曾经的风口“知识图谱”而言,如何找到其与chatgpt之间的区别,找好自身的定位显得尤为重要。形式化知识和参数化知识在表现形式上一直都是大家考虑的问题,两种技术都应该有自己的定位与价值所在。知识图谱构建往往是抽取式的,而且往往包含一系列知识冲突检测、消解过程,整个过程都能溯源。以这样的知识作为输入,能在相当程度上解决当前ChatGPT的事实谬误问题,并具有可解释性。

如何实现tomcat的热部署_tomcat热部署-程序员宅基地

文章浏览阅读1.3k次。最重要的一点,一定是degbug的方式启动,不然热部署不会生效,注意,注意!_tomcat热部署

用HTML5做一个个人网站,此文仅展示个人主页界面。内附源代码下载地址_个人主页源码-程序员宅基地

文章浏览阅读10w+次,点赞56次,收藏482次。html5 ,用css去修饰自己的个人主页代码如下:&lt;!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"&gt;&lt;html xmlns="http://www.w3.org/1999/xh..._个人主页源码

程序员公开上班摸鱼神器!有了它,老板都不好意思打扰你!-程序员宅基地

文章浏览阅读201次。开发者(KaiFaX)面向全栈工程师的开发者专注于前端、Java/Python/Go/PHP的技术社区来源:开源最前线链接:https://github.com/svenstaro/gen..._程序员怎么上班摸鱼

随便推点

UG\NX二次开发 改变Block UI界面的尺寸_ug二次开发 调整 对话框大小-程序员宅基地

文章浏览阅读1.3k次。改变Block UI界面的尺寸_ug二次开发 调整 对话框大小

基于深度学习的股票预测(完整版,有代码)_基于深度学习的股票操纵识别研究python代码-程序员宅基地

文章浏览阅读1.3w次,点赞18次,收藏291次。基于深度学习的股票预测数据获取数据转换LSTM模型搭建训练模型预测结果数据获取采用tushare的数据接口(不知道tushare的筒子们自行百度一下,简而言之其免费提供各类金融数据 , 助力智能投资与创新型投资。)python可以直接使用pip安装tushare!pip install tushareCollecting tushare Downloading https://files.pythonhosted.org/packages/17/76/dc6784a1c07ec040e74_基于深度学习的股票操纵识别研究python代码

中科网威工业级防火墙通过电力行业测评_电力行业防火墙有哪些-程序员宅基地

文章浏览阅读2k次。【IT168 厂商动态】 近日,北京中科网威(NETPOWER)工业级防火墙通过了中国电力工业电力设备及仪表质量检验测试中心(厂站自动化及远动)测试,并成为中国首家通过电力协议访问控制专业测评的工业级防火墙生产厂商。   北京中科网威(NETPOWER)工业级防火墙专为工业及恶劣环境下的网络安全需求而设计,它采用了非X86的高可靠嵌入式处理器并采用无风扇设计,整机功耗不到22W,具备极_电力行业防火墙有哪些

第十三周 ——项目二 “二叉树排序树中查找的路径”-程序员宅基地

文章浏览阅读206次。/*烟台大学计算机学院 作者:董玉祥 完成日期: 2017 12 3 问题描述:二叉树排序树中查找的路径 */#include #include #define MaxSize 100typedef int KeyType; //定义关键字类型typedef char InfoType;typedef struct node

C语言基础 -- scanf函数的返回值及其应用_c语言ignoring return value-程序员宅基地

文章浏览阅读775次。当时老师一定会告诉你,这个一个"warning"的报警,可以不用管它,也确实如此。不过,这条报警信息我们至少可以知道一点,就是scanf函数调用完之后是有一个返回值的,下面我们就要对scanf返回值进行详细的讨论。并给出在编程时利用scanf的返回值可以实现的一些功能。_c语言ignoring return value

数字医疗时代的数据安全如何保障?_数字医疗服务保障方案-程序员宅基地

文章浏览阅读9.6k次。十四五规划下,数据安全成为国家、社会发展面临的重要议题,《数据安全法》《个人信息保护法》《关键信息基础设施安全保护条例》已陆续施行。如何做好“数据安全建设”是数字时代的必答题。_数字医疗服务保障方案

推荐文章

热门文章

相关标签