GO学习之 多线程(goroutine)

GO系列

1、GO学习之Hello World
2、GO学习之入门语法
3、GO学习之切片操作
4、GO学习之 Map 操作
5、GO学习之 结构体 操作
6、GO学习之 通道(Channel)
7、GO学习之 多线程(goroutine)

文章目录

  • GO系列
  • 前言
  • 一、并发介绍
    • 1.1 进程和线程和协程
    • 1.2 并发和并行
  • 二、goroutine介绍
  • 三、goroutine操作
    • 3.1 超简单的函数调用
    • 3.2 go 关键字调用为啥没执行?
    • 3.3 go 关键字调用成了
    • 3.3 多个 go 一起 go
    • 3.4 main goroutine结束了,其他 goroutine呢?
  • 四、总结

前言

按照公司目前的任务,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 语言的学习阶段,想必有一些地方考虑的不全面,本文示例全部是亲自手敲代码并且执行通过。
如有问题,还请指教。
评论去告诉我哦!!!一起学习一起进步!!!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/59311.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Centos7 上安装 redis-dump 和redis-load 命令

一、安装rvm 1、安装GPG keys gpg2 --keyserver keyserver.ubuntu.com --recv-keys 409B6B1796C275462A1703113804BB82D39DC0E3 7D2BAF1CF37B13E2069D6956105BD0E739499BDBcurl -sSL http://rvm.io/mpapis.asc | gpg2 --import - curl -sSL http://rvm.io/pkuczynski.asc | g…

【C++】开源:matplotlib-cpp静态图表库配置与使用

&#x1f60f;★,:.☆(&#xffe3;▽&#xffe3;)/$:.★ &#x1f60f; 这篇文章主要介绍matplotlib-cpp图表库配置与使用。 无专精则不能成&#xff0c;无涉猎则不能通。——梁启超 欢迎来到我的博客&#xff0c;一起学习&#xff0c;共同进步。 喜欢的朋友可以关注一下&…

VLT:Vision-Language Transformer用于引用的视觉语言转换和查询生成分割

摘要 在这项工作中&#xff0c;我们解决了引用分割的挑战性任务。引用分割中的查询表达式通常通过描述目标对象与其他对象的关系来表示目标对象。因此&#xff0c;为了在图像中的所有实例中找到目标实例&#xff0c;模型必须对整个图像有一个整体的理解。为了实现这一点&#…

超全整理,Jmeter性能测试-常用Jmeter第三方插件详解(超细)

目录&#xff1a;导读 前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结&#xff08;尾部小惊喜&#xff09; 前言 Jmeter作为一个开…

不规则文件转JSON

需求分析&#xff1a; 有时候&#xff0c;我们取出来的数据并不是一个规则的JSON文件&#xff0c;这个时候面对存库还是ES检索都是一个问题&#xff0c;所以我们就需要进行解析&#xff0c;然而用字符串分割是不现实的&#xff0c;我们需要一种快速的方法。 问题解决&#x…

使用 Docker Compose 部署单机版 Redis:简单高效的数据缓存与存储

家人们啦&#xff01;今天我们来介绍如何使用 docker-compose 部署单机版 Redis&#xff0c;这是一个简单高效的数据缓存与存储解决方案&#xff0c;广泛应用于Web应用、移动应用以及各类数据处理场景。我们过后几篇文章了将会介绍cluster和sentinel集群的部署。通过本文的指导…

【LeetCode每日一题】——304.二维区域和检索-矩阵不可变

文章目录 一【题目类别】二【题目难度】三【题目编号】四【题目描述】五【题目示例】六【题目提示】七【解题思路】八【时间频度】九【代码实现】十【提交结果】 一【题目类别】 矩阵 二【题目难度】 中等 三【题目编号】 304.二维区域和检索-矩阵不可变 四【题目描述】 …

(学习笔记-进程管理)进程

进程 我们编写的代码只是一个存储在硬盘的静态文件&#xff0c;通过编译后会生成二进制可执行文件&#xff0c;当我们运行这个可执行文件后&#xff0c;它会被装载到内存中&#xff0c;接着CPU会执行程序中的每一条指令&#xff0c;那么这个运行中的程序就被称为进程。 现在我…

关于docker的一些深入了解

本文将深入介绍一下docker方面的知识&#xff0c;不尽完全&#xff0c;慢慢完善。 进程 进程的概念 在介绍docker的相关知识前&#xff0c;先了解一下相关概念。进程就是系统中正在运行的程序&#xff0c;进程是操作系统的概念&#xff0c;每当我们执行一个程序时&#xff0…

【unity】Pico VR 开发笔记(视角移动)

【unity】Pico VR 开发笔记&#xff08;视角移动&#xff09; 视角移动是简单的基础功能&#xff0c;这里区别于头显定位获得的小范围位移&#xff0c;是长距离不影响安全边界的位移方式。的常见的位移方式有两种&#xff0c;其一是触发后瞬间传送到指定位置&#xff0c;其次是…

Linux: 设置qmake的Qt版本

Qt开发&#xff0c;qmake会对应一个Qt版本&#xff0c;有时候需要切换这个版本&#xff0c;例如把qmake从Qt5.12切换到Qt5.9, 怎么操作呢&#xff1f; 案例如下&#xff1a; 银河麒麟V10系统&#xff0c;下载安装了Qt5.9.8&#xff0c;但是检查qmake发现它使用的是5.12.8&…

OPC DA 客户端与服务器的那点事

C#开发OPC客户端&#xff0c;使用OPCDAAuto.dll。在开发过程中偶遇小坎坷&#xff0c;主要记录一下问题解决办法。 1、建立客户端&#xff0c;参考链接。建立WinFrom工程&#xff0c;将博客中代码全部复制即可运行&#xff1a; https://www.cnblogs.com/kjgagaga/p/17011730.…

Java阶段五Day19

Java阶段五Day19 问题解析 需求单查询列表功能的bug 业务逻辑&#xff1a; 需要用户登录&#xff0c;师傅入驻&#xff0c;审核入驻通过 查询师傅详情&#xff08;areaIds&#xff0c;categoryIds&#xff09; demand-server-dao-impl 包含持久层实现 requestOrderMappe…

Vue——formcreate表单设计器自定义组件实现(二)

前面我写过一个自定义电子签名的formcreate表单设计器组件&#xff0c;那时初识formcreate各种使用也颇为生疏&#xff0c;不过总算套出了一个组件不是。此次时隔半年又有机会接触formcreate&#xff0c;重新熟悉和领悟了一番各个方法和使用指南。趁热打铁将此次心得再次分享。…

身体原来是一份宝贵的“情绪地图”, 疾病都在教导我们如何与世界相处

当我们生病时 很多时候&#xff0c;是一个契机 让我们来倾听自己内心的压抑的真实 聆听身体的声音 身体能够教会我们如何对待情绪 进而教导我们如何与世界相处 -1- 身体上&#xff0c;有你的情绪地图 皮肤是身体的镜子&#xff0c;身体则是心灵的镜子。生病&#xff0c…

什么是微服务

微服务的架构特征&#xff1a; 单一职责&#xff1a;微服务拆分粒度更小&#xff0c;每一个服务都对应唯一的业务能力&#xff0c;做到单一职责自治&#xff1a;团队独立、技术独立、数据独立&#xff0c;独立部署和交付面向服务&#xff1a;服务提供统一标准的接口&#xff0…

《Java-SE-第二十八章》之CAS

前言 在你立足处深挖下去,就会有泉水涌出!别管蒙昧者们叫嚷:“下边永远是地狱!” 博客主页&#xff1a;KC老衲爱尼姑的博客主页 博主的github&#xff0c;平常所写代码皆在于此 共勉&#xff1a;talk is cheap, show me the code 作者是爪哇岛的新手&#xff0c;水平很有限&…

AI绘图实战(十二):让AI设计LOGO/图标/标识 | Stable Diffusion成为设计师生产力工具

S&#xff1a;AI能取代设计师么&#xff1f; I &#xff1a;至少在设计行业&#xff0c;目前AI扮演的主要角色还是超级工具&#xff0c;要顶替&#xff1f;除非甲方对设计效果无所畏惧~~ 预先学习&#xff1a; 安装及其问题解决参考&#xff1a;《Windows安装Stable Diffusion …

Kali部署dvwa和pikachu靶场

kali换源 进入 vim /etc/apt/sources.list deb https://mirrors.aliyun.com/kali kali-rolling main non-free contrib deb-src https://mirrors.aliyun.com/kali kali-rolling main non-free contrib替换完后更新源 apt-get upadteDVWA靶场环境搭建 使用git从github上把DV…

项目中引用svg图标,公共组件SvgIcon使用,注册全局组件,使用自定义插件注册全局组件

在开发项目的时候经常会用到svg矢量图,而且我们使用SVG以后&#xff0c;页面上加载的不再是图片资源, 这对页面性能来说是个很大的提升&#xff0c;而且我们SVG文件比img要小的很多&#xff0c;放在项目中几乎不占用资源。 1、安装依赖插件 pnpm install vite-plugin-svg-ic…