GO学习之 多线程(goroutine)

news2024/11/27 12:52:23

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

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Android 中 app freezer 原理详解(二):S 版本

基于版本&#xff1a;Android S 0. 前言 在之前的两篇博文《Android 中app内存回收优化(一)》和 《Android 中app内存回收优化(二)》中详细剖析了 Android 中 app 内存优化的流程。这个机制的管理通过 CachedAppOptimizer 类管理&#xff0c;为什么叫这个名字&#xff0c;而不…

HTTP协议 和 HTTPS协议的区别(4点) HTTPS如何使用SSL/TLS协议加密过程 CA证书干啥的

&#xff08;一&#xff09;HTTP协议 和 HTTPS协议的区别&#xff08;4点&#xff09;&#xff1a; 1. HTTP协议的端口号是80&#xff0c; HTTPS协议的端口号是443 2. HTTP协议使用的URL是以 http:// 开头&#xff0c;HTTPS协议使用的URL是以https://开头 3. HTTP协议和HTTP…

Qt 中操作xml文件和JSON字符串

文章目录 1、概述1.1、xml介绍1.2、json介绍 2、xml文件增删改查2.1、写xml文件内容2.2、读xml文件内容2.3、删除xml文件内容2.4、修改xml文件内容 3、构建JSON字符串3.1、JSON字符串排版4、剪切板操作 1、概述 1.1、xml介绍 XML 指可扩展标记语言&#xff08;EXtensible Mark…

“效能指标”,该由谁来定义?| 谈效风生

第5期&#xff1a;效能指标&#xff0c;该由谁来定义&#xff1f; 回顾上期《「自动化」聊起来简单&#xff0c;做起来难》我们聊了聊如何打造「自动化」的事&#xff0c;这也是真正实现研发效能提升的必要条件。从单点自动化提升效率&#xff0c;到全工具链自动化&#xff0c;…

常微分方程建模R包ecode(二)——绘制相速矢量场

本节中我们考虑一个更为复杂的常微分方程模型&#xff0c; d X C d t ν ( X A Y A ) − β ⋅ X C ⋅ ( Y C Y A ) − ( μ g ) ⋅ X C , ( 1 ) d Y C d t β ⋅ X C ⋅ ( Y C Y A ) − ( μ g ρ ) ⋅ Y C , ( 2 ) d X A d t g ⋅ X C − β ⋅ X A ⋅ ( Y C Y A …

2023最新版本~十分钟零基础搭建EMQX服务器

购买服务器 已知服务器大厂商 1 阿里云 点击直接访问 2 华为云点击直接访问 3 腾讯云 点击直接访问 还是比较推荐大公司 不会跑路 这里我购买的是一年的华为云服务器(新用户 64一年) 镜像推荐乌班图18 登陆服务器&#xff08;需要重置密码&#xff01;&#xff01;&…

Ansible自动化运维工具 —— Playbook 剧本

playbooks 本身由以下各部分组成 &#xff08;1&#xff09;Tasks&#xff1a;任务&#xff0c;即通过 task 调用 ansible 的模板将多个操作组织在一个 playbook 中运行 &#xff08;2&#xff09;Variables&#xff1a;变量 &#xff08;3&#xff09;Templates&#xff1a;模…

ubuntu16.04忘记密码了怎么办,亲测有效

由于装载Ubuntu系统的电脑&#xff08;非虚拟机&#xff09;好久没有用&#xff0c;忘记了密码&#xff0c;只能进行密码重置&#xff0c;亲测有效&#xff1a; 1.首先ubuntu系统开机&#xff0c;期间按着shift键不放&#xff0c;选择高级选项。 2.enter键进入如下界面&#x…

python-occ入门指北

0、系统环境: Win10 在Windows环境中玩PythonOCC比较简单的方式是使用anaconda的cmd prompt或者powershell的prompt&#xff0c;这里我用的是cmd。PowerShell也有很多粉丝&#xff0c;但是个人真的觉得这个东西挺鸡肋的。 另外在Win10或Win11上另一个玩法是使用WSL2&#xff…

【漏洞挖掘】Xray+rad自动化批量漏洞挖掘

文章目录 前言一、挖掘方法二、使用步骤工具安装使用方法开始挖掘 总结 前言 自动化漏洞挖掘是指利用计算机程序和工具来扫描、分析和检测应用程序、网络和系统中的安全漏洞的过程。这种方法可以帮助安全专家和研究人员更高效地发现和修复潜在的安全威胁&#xff0c;从而提高整…

企业级开发中协同开发与持续集成持续部署

文章目录 1 创建代码仓库2 使用git协同开发2.1 独立团队开发2.2 多团队开发git工作流 2 持续集成和持续部署2.1 创建docker镜像2.2 使用coding构建 1 创建代码仓库 每个项目有唯一的代码仓库&#xff0c;所以不是每个开发者都需要创建一个代码仓库&#xff0c;一般都是项目负责…

Node版本自由切换之nvm安装教程

1.nvm安装包下载&#xff0c;这里推荐1.1.7版本 https://github.com/coreybutler/nvm-windows/releases/download/1.1.7/nvm-setup.zip 2.解压后运行exe文件&#xff0c;一路默认就可以了&#xff0c;自定义的话&#xff0c;文件路径不要有中文&#xff1b; 3.安装之后使用命…

CloudCompare软件手册01

1. 介绍 1.1 历史 CloudCompare是一个3D点云(和三角形网格)编辑和处理软件。 最初&#xff0c;它被设计用于在密集的3D点云之间进行直接比较。它依赖于一种特定的八叉树结构&#xff0c;在执行这类任务时&#xff0c;这种结构能够提供出色的性能。此外&#xff0c;由于大多数…

基于python+Xception算法模型实现一个图像分类识别系统

一、目录 Xception介绍数据集处理模型训练模型评估项目扩展 二、Xception介绍 在计算机视觉领域&#xff0c;图像识别是一个非常重要的任务&#xff0c;其应用涵盖了人脸识别、物体检测、场景理解等众多领域。随着深度学习技术的发展&#xff0c;深度卷积神经网络&#xff0…

C++继承——多继承问题

目录 单继承&#xff1a; 多继承&#xff1a; 菱形继承&#xff1a;菱形继承是多继承的一种特殊情况。 三.菱形继承的两种解决方式区别&#xff1a; 3.1采用作用域解决的菱形继承&#xff1a; 检测器运行图&#xff1a; 反汇编运行图&#xff1a; 3.1菱形虚继承&…

webstorm配置less转译

Program中路径如果识别不到 项目文件\node_modules.bin\lessc

如何优雅的显示404页面

源码&#xff1a;mumangguo/404-notfound - 码云 - 开源中国https://gitee.com/mumangguo/404-notfound 1.孤独型404页面 2.酷炫效果404页面 3.太空404页面 4.404寻亲页面&#xff08;公益&#xff09; 每一次刷新都是一个公益捐赠活动&#xff01; 以上就是笔者要分享的4个4…

【H5移动端】常用的移动端方案合集-键盘呼起、全面屏适配、图片大小显示、300ms点击延迟、首屏优化(不定期补充~)

文章目录 前言键盘呼起问题靠近底部的输入项被键盘遮挡底部按钮被顶上去 全面屏适配图片大小显示问题解决300ms延迟首屏优化 前言 这篇文章总结了我在工作中做H5遇到的一些问题&#xff0c;包括我是怎么解决的。可能不是当下的最优解&#xff0c;但是能保证解决问题。 单位适…

【hive】Install hive using mysql as hive metadata service

文章目录 一. Requirements二. Installing Hive from a Stable Release三. Running Hive四. Running Hive CLI五.Running HiveServer2 and Beeline1. 下载安装mysql2. 下载mysql驱动3. 配置hive-site.xml4. 初始化元数据库5. 通过beeline进行连接 一. Requirements Users are s…

简易博客系统自动化测试

&#x1f349;作者 Autumn60 &#x1f3c4;欢迎关注&#xff1a;&#x1f44d;点赞&#x1f64c;收藏✍️留言 &#x1f472;微语 &#xff1a;只有镜子和钱包&#xff0c;可以告诉你生活中&#xff0c;大部分的为什么和凭什么 文章目录 目录 文章目录 概述: 测试方法&am…