Golang协程的概念、用法、场景及案例

在当今的软件开发领域中，高性能和并发性是很重要的。开发人员需要编写能够有效利用多核处理器的程序，以提高应用程序的性能和响应能力。Go语言（Golang）就是一种在这方面非常强大的编程语言，它提供了一种称为协程（Goroutine）的并发模型。

什么是Golang协程？

协程是一种轻量级的线程，它可以实现并发执行的并行操作。协程是Go语言中的一个核心特性，它使得程序能够以并发的方式运行，并且非常高效。与传统的线程相比，协程的创建和销毁成本非常低，可以方便地启动大量的协程来执行并行操作。

Golang的协程不同于其他语言中的线程或进程，它们是由Go语言的运行时系统调度的。协程的调度是基于协作式的，即协程自己主动让出CPU的控制权，而不是依赖于操作系统的调度器。

Golang协程的用法

在Go语言中，要创建一个协程，只需在函数调用前加上关键字"go"。下面是一个简单的示例：

go 函数名()

这样就创建了一个新的协程，并在该协程中执行相应的函数。协程会与主线程并发执行，不会阻塞主线程的执行。

协程之间可以通过通道（Channel）进行通信。通道是一种在多个协程之间同步和传递数据的机制，它能够保证并发安全。通过通道，协程可以发送和接收数据，实现协程之间的协作。

在下面的示例中，我们创建了一个协程来执行耗时的操作，并通过通道将结果返回给主线程：

package mainimport ("fmt""time"
)func longRunningTask() int {time.Sleep(time.Second)return 42
}func main() {result := make(chan int)go func() {result <- longRunningTask()}()fmt.Println("Waiting for result...")fmt.Println("Result:", <-result)
}

在上面的示例中，我们使用了匿名函数来创建一个协程，并通过通道将结果发送给主线程。在主线程中，我们等待结果的返回并打印出来。通过使用协程和通道，我们可以在执行耗时操作时不阻塞主线程的执行。

Golang协程的场景

Golang的协程非常适用于以下场景：

1. 并发执行任务

协程可以非常方便地启动大量的任务并发执行，提高程序的性能和吞吐量。在计算密集型的任务中，可以利用多个协程进行并行计算，加快任务的执行速度。在IO密集型的任务中，可以通过协程来并发处理多个IO操作，提高程序的响应能力。

2. 高并发服务器

协程非常适合用于构建高并发的服务器程序。通过协程和通道，可以实现高效的并发编程模型。每个客户端连接可以对应一个协程，这样可以同时处理多个客户端请求，提高服务器的并发处理能力。

3. 异步IO操作

协程可以很方便地处理异步IO操作。通过协程和通道，可以实现非阻塞的IO操作，并在IO操作完成后通知相应的协程继续执行。这样可以避免在IO操作上浪费过多的时间，提高程序的响应速度。

Golang协程的案例

下面是一个使用协程和通道的案例，展示了如何并发下载多个文件：

package mainimport ("fmt""io/ioutil""net/http""time"
)func downloadFile(url string, c chan<- string) {resp, err := http.Get(url)if err != nil {c <- fmt.Sprintf("Error: %v", err)return}defer resp.Body.Close()data, err := ioutil.ReadAll(resp.Body)if err != nil {c <- fmt.Sprintf("Error: %v", err)return}filename := fmt.Sprintf("%d.txt", time.Now().UnixNano())err = ioutil.WriteFile(filename, data, 0644)if err != nil {c <- fmt.Sprintf("Error: %v", err)return}c <- fmt.Sprintf("Success: %s", filename)
}func main() {urls := []string{"https://example.com/file1.txt","https://example.com/file2.txt","https://example.com/file3.txt",}results := make(chan string)for _, url := range urls {go downloadFile(url, results)}for _ = range urls {fmt.Println(<-results)}
}

在上面的案例中，我们创建了一个协程来下载每个文件，并将下载结果发送到结果通道中。主线程等待所有协程完成下载，并将结果从结果通道中接收并打印出来。

通过使用协程，我们可以并发地下载多个文件，提高下载的效率。
当然，下面我将为你介绍3个使用Golang协程的案例，并提供相应的代码和讲解。

案例1: 并发计算斐波那契数列

斐波那契数列是一个经典的计算问题，下面的示例展示了如何使用协程并发地计算斐波那契数列中的第n个数字。

package mainimport ("fmt""time"
)func fibonacci(n int, c chan<- int) {x, y := 0, 1for i := 0; i < n; i++ {c <- xtime.Sleep(time.Millisecond * 100) // 模拟计算耗时x, y = y, x+y}close(c)
}func main() {c := make(chan int)go fibonacci(10, c)for num := range c {fmt.Println(num)}
}

在上面的代码中，我们定义了一个fibonacci函数，它使用协程并发地计算斐波那契数列中的前n个数字，并将结果发送到通道c中。在main函数中，我们通过range语句从通道中读取结果并打印出来。

案例2: 并发爬取网页内容

在网络爬虫的场景中，我们通常需要并发地爬取多个网页的内容。下面的示例展示了如何使用协程并发地爬取多个网页的内容，并将结果发送到通道。

package mainimport ("fmt""io/ioutil""net/http"
)func crawl(url string, c chan<- string) {resp, err := http.Get(url)if err != nil {c <- fmt.Sprintf("Error: %v", err)return}defer resp.Body.Close()body, err := ioutil.ReadAll(resp.Body)if err != nil {c <- fmt.Sprintf("Error: %v", err)return}c <- string(body)
}func main() {urls := []string{"https://example.com","https://google.com","https://github.com",}results := make(chan string)for _, url := range urls {go crawl(url, results)}for i := 0; i < len(urls); i++ {fmt.Println(<-results)}
}

在上面的代码中，我们定义了一个crawl函数，它使用协程并发地爬取每个给定的URL的内容，并将结果发送到通道results中。在main函数中，我们遍历URL列表，并使用协程同时爬取多个网页的内容。然后，通过读取通道中的结果，我们将每个网页的内容打印出来。

案例3: 并发处理图片处理任务

在图像处理的场景中，我们通常需要并发地处理大量的图片。下面的示例展示了如何使用协程并发地处理多个图片，并将结果发送到通道。

package mainimport ("fmt""image""image/jpeg""io/ioutil""os""path/filepath"
)func processImage(filename string, c chan<- string) {file, err := os.Open(filename)if err != nil {c <- fmt.Sprintf("Error: %v", err)return}defer file.Close()img, err := jpeg.Decode(file)if err != nil {c <- fmt.Sprintf("Error: %v", err)return}// 图像处理逻辑...// 这里只是简单地将图片大小调整为50x50像素resized := resize(img, 50, 50)// 保存处理后的图片outputFilename := filepath.Join("output", filepath.Base(filename))outputFile, err := os.Create(outputFilename)if err != nil {c <- fmt.Sprintf("Error: %v", err)return}defer outputFile.Close()err = jpeg.Encode(outputFile, resized, nil)if err != nil {c <- fmt.Sprintf("Error: %v", err)return}c <- fmt.Sprintf("Success: %s", outputFilename)
}func resize(img image.Image, width, height int) image.Image {// 图像缩放逻辑...// 这里只是简单地调整图像大小return image.NewRGBA(image.Rect(0, 0, width, height))
}func main() {// 获取所有图片文件files, err := ioutil.ReadDir("images")if err != nil {fmt.Println(err)return}results := make(chan string)for _, file := range files {go processImage(filepath.Join("images", file.Name()), results)}for i := 0; i < len(files); i++ {fmt.Println(<-results)}
}

在上面的代码中，我们定义了一个processImage函数，它使用协程并发地处理每个给定的图片。在这个示例中，我们只是简单地将图片的大小调整为50x50像素，并保存到output目录中。在main函数中，我们遍历图片文件夹中的所有图片文件，并使用协程并发地处理每个图片。然后，通过读取通道中的结果，我们将每个处理后的图片的文件名打印出来。

总结

Golang的协程是一种非常强大的并发模型，可以帮助我们编写高效的并发程序。协程通过轻量级的线程来实现并发执行的并行操作，可以充分利用多核处理器，提高程序的性能和响应能力。

协程之间通过通道进行通信，可以实现数据的同步和传递。通道可以保证并发安全，避免竞态条件和资源竞争等问题。

协程适用于许多场景，包括并发执行任务、构建高并发服务器和处理异步IO操作等。通过协程，我们可以实现高效的并发编程模型，提高程序的并发处理能力和响应速度。

希望本文对您了解和使用Golang协程有所帮助。如果您对Golang协程还有任何疑问，请随时提问。

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

CentOS（5）——rpm包和源码包区别

CentOS（5）——rpm包和源码包区别

目录 一、简介 二、区别 ①包名称 ②概念 ③优缺点 ④安装位置的区别 ⑤安装位置不同带来的影响 ⑥卸载方式的不同 一、简介 最近在公司内网离线升级Git时&#xff0c;遇见两个概念&#xff0c;分别是使用rpm包安装git&#xff0c;另一个这是编译源码包安装git&#x…
阅读更多...
Spring MVC(上)

Spring MVC(上)

1、Spring MVC简介&#xff1a; MVC是一种软件架构的思想&#xff0c;将软件按照模型、视图、控制器来划分 M&#xff1a;Model&#xff0c;模型层&#xff0c;指工程中的JavaBean&#xff0c;作用是处理数据 JavaBean分为两类&#xff1a; 一类称为实体类Bean&#xff1a;专…
阅读更多...
语法分析出错，不是 GROUP BY 表达式

语法分析出错，不是 GROUP BY 表达式

报错 ### Cause: dm.jdbc.driver.DMException: 第 9 行, 第 69 列[30]附近出现错误: 语法分析出错 ; bad SQL grammar []; nested exception is dm.jdbc.driver.DMException: 第 9 行, 第 69 列[30]附近出现错误: 语法分析出错at org.springframework.jdbc.support.SQLState…
阅读更多...
Java后端开发（五）-- 对象转换工具类

Java后端开发（五）-- 对象转换工具类

为避免返回给前端的字段信息太多，在缓解前、后端通信的带宽压力的前提下，对不必要的字段的信息进行不返回时，entity层对象需要向vo层对象进行转换，同事尽量减少geetter与setter方法的编码。 1. ConvertUtils工具类 import org.slf4j.Logger; import org.slf4j.LoggerFacto…
阅读更多...
【Godot引擎开发】简单基础，外加一个小游戏DEMO

【Godot引擎开发】简单基础，外加一个小游戏DEMO

博主&#xff1a;_LJaXi 专栏&#xff1a; Godot | 横版游戏开发 Godot 物体规律移动内置虚函数浮点计算浮点数计算数组APIInput单例与自定义单例节点NodeSprite2DArea2DCollisionShape2DKinematicBody2DRigidBody2D Pong游戏场景安排玩家1玩家2小球记分系统文件概要 下面是介绍…
阅读更多...
【C++】C++学习（模板+排序+测时）

【C++】C++学习（模板+排序+测时）

本文主要记录使用模板函数来编写排序算法&#xff0c;并计算运行时间。 模板函数&#xff08;Template Function&#xff09;是一种通用函数&#xff0c;可以在其定义时不指定具体的参数类型&#xff0c;在调用时再根据需要指定具体类型。模板函数可以接受不同类型的参数&…
阅读更多...
『力扣刷题本』：相交链表

『力扣刷题本』：相交链表

咳咳&#xff0c;实在抱歉&#xff0c;刚开始心气太高了&#xff0c;叫『每日一题』&#xff0c;我是真的坚持不下了。 经过这次打击&#xff0c;我算是摸明白自己在写博客这件事情上几斤几两了&#xff0c;现在预计一周两更&#xff0c;再慢慢把更新频率提上来。 正在努力补…
阅读更多...
DRM中render-node编号的分配

DRM中render-node编号的分配

DRM系统 DRM是direct rendering manager的简称。DRM是linux kernel中与负责video cards功能的GPU打交道的子系统。DRM给出了一组API&#xff0c;可以供用户程序来发送命令和数据给GPU设备从而来控制比如display、render等功能。 render-node由来 在以前&#xff0c;DRM子系统…
阅读更多...
Java数字处理类-- Math类--数学运算

Java数字处理类-- Math类--数学运算

在Java中提供了一个执行数学基本运算的Math类,该类包括了常用的数学运算方法和常量&#xff0c;包括【三角函数方法】&#xff0c;【指数函数方法】&#xff0c;【取整函数方法】、【取最大值函数方法】、【取最小值函数方法】、【取平均值函数方法】、【对数函数方法】&#x…
阅读更多...
MSF入门

MSF入门

漏洞数据库、利用工具集MSF MSF: The Metasploit Framework 简称美少妇 MSF安装 安装平台 Kali Linux: 自带Linux: 阿里云CentOS7安装msfWindows.msi 使用方式 msfconsole 交互终端 msfcli . msfconsole -x"command:..."图形界面: artimate、viper 下面我会用…
阅读更多...
ES6 Class和Class继承

ES6 Class和Class继承

1.class的基本语法 class可以理解为是一个语法糖&#xff0c;将js只能通过构造函数创建实例的方法进行了补充 构造函数&#xff1a; function Person ({ name, age18 }) {this.name namethis.age age } new Person({name: 张三}) Class类&#xff1a; class Person {con…
阅读更多...
SLAM从入门到精通（构建自己的slam包）

SLAM从入门到精通（构建自己的slam包）

【 声明&#xff1a;版权所有&#xff0c;欢迎转载&#xff0c;请勿用于商业用途。 联系信箱&#xff1a;feixiaoxing 163.com】 我们学习了很多的开源包&#xff0c;比如hector、gmapping。但其实我们也可以自己编写一个slam包。这么做最大的好处&#xff0c;主要还是可以帮助…
阅读更多...
抽象轻松的java

抽象轻松的java

先看问题代码和运行结果 public static void main(String[] args) {Scanner scanner new Scanner(System.in);System.out.println("输入一串数字");int i scanner.nextInt();System.out.println("i&#xff1a;" i);int z scanner.nextInt();System.ou…
阅读更多...
宏(预编译)详解

宏(预编译)详解

目录 一、程序的编译环境 二、运行环境 三、预编译详解 3.1预定义符号 3.2.1 #define 定义标识符 3.2.2 #define 定义宏 3.2.3#define替换规则 3.2.4 #和## 2)##的作用&#xff1a; 3.2.5宏和函数的对比 3.2.6宏的命名约定和#undef指令 一、命名约定&#xff1a; …
阅读更多...
学信息系统项目管理师第4版系列32_信息技术发展

学信息系统项目管理师第4版系列32_信息技术发展

1. 大型信息系统 1.1. 大型信息系统是指以信息技术和通信技术为支撑&#xff0c;规模庞大&#xff0c;分布广阔&#xff0c;采用多级 网络结构&#xff0c;跨越多个安全域&#xff1b;处理海量的&#xff0c;复杂且形式多样的数据&#xff0c;提供多种类型应用 的大系统 1.1.…
阅读更多...
【常用图像增强技术，Python-opencv】

【常用图像增强技术，Python-opencv】

文章目录 常用图像增强技术调整大小灰度变换标准化随机旋转中心剪切随机裁剪高斯模糊亮度、对比度和饱和度调节水平翻转垂直翻转高斯噪声随机块中心区域 常用图像增强技术 图像增强技术是常用于数据增强的方法&#xff0c;可以帮助增加数据集中图像的多样性&#xff0c;提高深…
阅读更多...
webpack 项目升级成vite项目

webpack 项目升级成vite项目

将webpack升级成vite得步骤&#xff1a; 1.把 public/index.html 移动到项目根目录&#xff0c;把文件中的 %PUBLIC_URL% 去掉 // %PUBLIC_URL%就是指向对应的public文件夹的绝对路径2.把 src/index.js 入口文件 &#xff0c;改成 src/main.ts &#xff0c;并在 index.html 文…
阅读更多...
论文阅读：Point-to-Voxel Knowledge Distillation for LiDAR Semantic Segmentation

论文阅读：Point-to-Voxel Knowledge Distillation for LiDAR Semantic Segmentation

来源&#xff1a;CVPR 2022 链接&#xff1a;https://arxiv.org/pdf/2206.02099.pdf 0、Abstract 本文解决了将知识从大型教师模型提取到小型学生网络以进行 LiDAR 语义分割的问题。由于点云的固有挑战&#xff0c;即稀疏性、随机性和密度变化&#xff0c;直接采用以前的蒸馏…
阅读更多...
Mapping 设计指南

Mapping 设计指南

Mapping 设计指南 目录概述需求&#xff1a; 设计思路实现思路分析1、properties2.fields 3.search_analyzer4.2、format1、enabled2、doc_values 参考资料和推荐阅读 Survive by day and develop by night. talk for import biz , show your perfect code,full busy&#xff0…
阅读更多...
ROS自学笔记十二：Command ‘git‘ not found, but can be installed with:

ROS自学笔记十二：Command ‘git‘ not found, but can be installed with:

这个错误提示表明在你的系统上未安装Git命令行工具。你可以按照以下步骤在不同的操作系统上安装Git&#xff1a; 在Linux上安装Git Ubuntu/Debian&#xff1a; sudo apt update sudo apt install git Fedora&#xff1a; sudo dnf install git CentOS&#xff1a; sudo yu…
阅读更多...
最新文章

Copyright @ 2022~2023