10.3 Go 同步与通信


在这里插入图片描述
💝💝💝欢迎莅临我的博客,很高兴能够在这里和您见面!希望您在这里可以感受到一份轻松愉快的氛围,不仅可以获得有趣的内容和知识,也可以畅所欲言、分享您的想法和见解。
在这里插入图片描述

  • 推荐:「stormsha的主页」👈,持续学习,不断总结,共同进步,为了踏实,做好当下事儿~

  • 专栏导航

    • Python系列: Python面试题合集,剑指大厂
    • Git系列: Git操作技巧
    • GO系列: 记录博主学习GO语言的笔记,该笔记专栏尽量写的试用所有入门GO语言的初学者
    • 数据库系列: 详细总结了常用数据库 mysql 技术点,以及工作中遇到的 mysql 问题等
    • 运维系列: 总结好用的命令,高效开发
    • 算法与数据结构系列: 总结数据结构和算法,不同类型针对性训练,提升编程思维

    非常期待和您一起在这个小小的网络世界里共同探索、学习和成长。💝💝💝 ✨✨ 欢迎订阅本专栏 ✨✨

    💖The Start💖点点关注,收藏不迷路💖

    📒文章目录

      • Goroutine:轻量级的并发
        • 技巧 1:合理使用 Goroutines
        • 技巧 2:利用 WaitGroup 同步 Goroutines
      • Channels:Go 语言的通信机制
        • 技巧 3:使用 Buffered Channels 控制数据流
        • 技巧 4:利用 Channels 实现同步
        • 技巧 5:使用 Select 进行多路复用
      • 错误处理与超时
        • 技巧 6:使用 ErrGroup 处理并发错误
        • 技巧 7:设置超时控制
      • 总结


内容内容内容内容内容内容内容内容内容内容内容内容内容内容内容内容内容内容内容
在 Go 语言的并发编程中,同步和通信是构建高效、稳定程序的关键。Go 通过 goroutines 和 channels 为开发者提供了一套简洁而强大的并发模型。本文将深入探讨 Go 中的同步与通信机制,分享一些使用技巧,旨在帮助开发者更好地理解和应用这些概念。

Goroutine:轻量级的并发

Go 语言的 goroutines 是实现并发的基石。它们是轻量级的线程,由 Go 运行时管理,可以在用户级别进行调度。Goroutine 的创建非常简单,只需要使用 go 关键字:

go myFunction()

技巧 1:合理使用 Goroutines

虽然 goroutines 可以轻松创建,但过多的 goroutines 会消耗系统资源。合理控制 goroutines 的数量,避免不必要的并发,可以提高程序的性能。

技巧 2:利用 WaitGroup 同步 Goroutines

当需要等待多个 goroutines 完成时,可以使用 sync.WaitGroup。它允许你等待一组 goroutines 完成它们的任务:

var wg sync.WaitGroupfor _, task := range tasks {go func() {defer wg.Done()processTask(task)}()
}wg.Wait() // 等待所有 goroutines 完成

Channels:Go 语言的通信机制

Channels 是 Go 语言中实现 goroutines 间通信的机制。它们可以传递数据,并支持同步操作。

技巧 3:使用 Buffered Channels 控制数据流

Channels 可以是带缓冲的,这意味着它们可以存储一定数量的值,直到被读取。使用带缓冲的 channels 可以控制数据流,防止生产者过快地生成数据,而消费者跟不上:

ch := make(chan int, 10) // 创建一个缓冲大小为 10 的 channel

技巧 4:利用 Channels 实现同步

Channels 不仅可以用来传递数据,还可以用来同步 goroutines。例如,使用 channels 来实现一个 barrier,等待所有 goroutines 到达某个点:

done := make(chan bool)
for i := 0; i < 5; i++ {go func() {// 执行一些任务<-done // 等待信号}()
}
close(done) // 发送信号,所有 goroutines 将被解锁

技巧 5:使用 Select 进行多路复用

select 语句允许你同时等待多个 channel 操作,这在处理多个 goroutines 间的通信时非常有用:

select {
case msg := <-ch1:handle(ch1, msg)
case msg := <-ch2:handle(ch2, msg)
default:handleDefault()
}

错误处理与超时

在并发编程中,错误处理和超时控制是必不可少的。

技巧 6:使用 ErrGroup 处理并发错误

errgroup.Group 是一个处理一组 goroutines 并收集它们错误的方法。当其中一个 goroutine 返回错误时,errgroup 会取消其他所有 goroutines 并返回第一个遇到的错误:

eg := errgroup.Group{}
for _, task := range tasks {eg.Go(func() error {return processTask(task)})
}
if err := eg.Wait(); err != nil {log.Fatal(err)
}

技巧 7:设置超时控制

在某些情况下,你可能需要对 goroutine 的执行设置超时。这可以通过组合 channels 和 time. After 来实现:

timeout := time.After(5 * time.Second)
select {
case result := <-taskChannel:handleResult(result)
case <-timeout:log.Println("Operation timed out")
}

总结

Go 语言的并发模型以其简单性和效率而闻名。通过合理使用 goroutines 和 channels,开发者可以构建出既快速又可靠的并发程序。本文介绍的技巧和最佳实践可以帮助开发者更深入地理解 Go 的同步与通信机制,并在实际开发中运用这些知识。

记住,同步和通信是并发编程的核心,正确地使用它们可以极大地提升程序的性能和稳定性。希望本文能够帮助你更有效地使用 Go 语言进行并发编程。


🔥🔥🔥道阻且长,行则将至,让我们一起加油吧!🌙🌙🌙

💖The End💖点点关注,收藏不迷路💖

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

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

相关文章

Android Studio Jellyfish版本修改project使用特定jdk版本的步骤

android studio总是把这些东西改来改去让人十分恼火&#xff0c;IDE本身改来改去就让人无法上手就立即工作&#xff0c;很多时间浪费在IDE和gradle的配置和奇奇怪怪现象的斗智斗勇上&#xff0c;搞Android是真的有点浪费生命。一入此坑深不见底 jellyfish版安卓studio已经无法通…

Docker高级篇之轻量化可视化工具Portainer

文章目录 1. 简介2. Portainer安装 1. 简介 Portianer是一款轻量级的应用&#xff0c;它提供了图形化界面&#xff0c;用于方便管理Docker环境&#xff0c;包括单机环境和集成环境。 2. Portainer安装 官网&#xff1a;https://www.portainer.io 这里我们使用docker命令安装&…

状态管理Vuex

官网&#xff1a;Vuex 是什么&#xff1f; | Vuex (vuejs.org)https://v3.vuex.vuejs.org/zh/ 创建一个vue2的新项目名为vuex-demo&#xff0c;安装命令 npm install vuex3 新建index.js import Vue from vue import Vuex from vuexVue.use(Vuex)const store new Vuex.Store(…

记录自己在xss-labs的通关记录

第十一关&#xff08;referer&#xff09; 直接查看网页源代码&#xff0c;发现四个input被隐藏&#xff0c;不难看出&#xff0c;第四个名为t_ref的<input>标签是http头referer的参数&#xff08;就是由啥地址转跳到这里的&#xff0c;http头的referer会记录有&#xf…

操作系统安全:Windows系统安全配置,Windows安全基线检查加固

「作者简介」&#xff1a;2022年北京冬奥会网络安全中国代表队&#xff0c;CSDN Top100&#xff0c;就职奇安信多年&#xff0c;以实战工作为基础对安全知识体系进行总结与归纳&#xff0c;著作适用于快速入门的 《网络安全自学教程》&#xff0c;内容涵盖系统安全、信息收集等…

如何用R语言ggplot2画折线图

文章目录 前言一、数据集二、ggplot2画图1、全部代码2、细节拆分1&#xff09;导包2&#xff09;创建图形对象3&#xff09;主题设置4&#xff09;轴设置5&#xff09;图例设置6&#xff09;颜色7&#xff09;保存图片 前言 一、数据集 数据下载链接见文章顶部 数据&#xff1a…

STM32 Customer BootLoader 刷新项目 (一) STM32CubeMX UART串口通信工程搭建

STM32 Customer BootLoader 刷新项目 (一) STM32CubeMX UART串口通信工程搭建 文章目录 STM32 Customer BootLoader 刷新项目 (一) STM32CubeMX UART串口通信工程搭建功能与作用典型工作流程 1. 硬件原理图介绍2. STM32 CubeMX工程搭建2.1 创建工程2.2 系统配置2.3 USART串口配…

tokenization(一)概述

文章目录 背景基于词&#xff08;Word-based&#xff09;基于字符&#xff08;Character-based&#xff09;子词词元化&#xff08;Subword tokenization&#xff09; 背景 tokenization是包括大语言模型在内所有自然语言处理的任务的基础步骤&#xff0c;其目标是将文本数据转…

【面试干货】聚集索引和非聚集索引区别?

【面试干货】聚集索引和非聚集索引区别? 1、聚集索引&#xff08;Clustered Index&#xff09;1.1 特点1.2 例子 2、非聚集索引&#xff08;Nonclustered Index&#xff09;2.1 特点2.2 例子 3、根本区别 &#x1f496;The Begin&#x1f496;点点关注&#xff0c;收藏不迷路&…

Sklearn的安装和用法

安装sklearn相对简单&#xff0c;因为它是一个Python库&#xff0c;可以通过Python的包管理器pip来安装。 Windows、macOS和Linux通用步骤&#xff1a; 确保Python已安装&#xff1a; sklearn是基于Python的&#xff0c;所以首先确保你的计算机上安装了Python。推荐使用Pytho…

NLP——电影评论情感分析

python-tensorflow2.0 numpy 1.19.1 tensorflow 2.0.0 导入库 数据加载 数据处理 构建模型 训练 评估 预测 1.基于2层dropout神经网络 2.基于LSTM的网络 #导入需要用到的库 import os import tarfile import urllib. request import tensorflow as tf import numpy a…

5W-35W-150W-300W-500W铝壳功率电阻器

带铝制外壳的电阻器 EAK采用铝型材的导线电阻器将久经考验的导线材料的高脉冲稳定性与优化的导热和高度保护相结合。安装在导热表面上可进一步改善散热并提高稳定性。 连接线有各种长度和材料可供选择。可选配集成温度开关。也可根据客户要求提供定制组件。 该产品有多种版本…

CVE-2023-37474(目录遍历)

靶场简介 Copyparty是一个可移植的文件服务器。在1.8.2版本之前的版本存在一个CTF技巧&#xff0c;该漏洞位于.cpr子文件夹中。路径遍历攻击技术允许攻击者访问位于Web文档根目录之外的文件、目录. 靶场 进入靶场 根据简介访问.cpr目录 使用curl命令访问etc/passwd文件 确定…

kettle_Hbase

kettle_Hbase ☀Hbase学习笔记 读取hdfs文件并将sal大于1000的数据保存到hbase中 前置说明&#xff1a; 1.需要配置HadoopConnect 将集群中的/usr/local/soft/hbase-1.4.6/conf/hbase-site.xml复制至Kettle中的 Kettle\pdi-ce-8.2.0.0-342\data-integration\plugins\pentah…

8.1 基本打印功能

本文仅供学习交流&#xff0c;严禁用于商业用途&#xff0c;如本文涉及侵权请及时联系本人将于及时删除 在使用“MFC应用”项目模板生成应用程序的过程中&#xff0c;如果在“高级功能”窗口中不取消对打印和打印预览的设置&#xff0c;那么应用程序就已经具备了简单的打印和打…

MySQL—多表查询—练习(2)

一、引言 接着上篇博客《 MySQL多表查询——练习&#xff08;1&#xff09;》继续完成剩下的案例需求。 二、案例 &#xff08;0&#xff09;三张表&#xff08;员工表、部门表、薪资等级表&#xff09; 员工表&#xff1a;emp 部门表&#xff1a;dept 薪资等级表&#xff1a;…

使用 PlatformIO 将文件上传到 ESP32-S3 的 SPIFFS 文件系统

PlatformIO环境 将文件上传到 ESP32-S3 的 SPIFFS 文件系统 介绍&#xff1a; PlatformIO 是一个流行的开发平台&#xff0c;用于编写、构建和上传嵌入式项目。ESP32-S3 是 Espressif 推出的一款功能强大的嵌入式开发板&#xff0c;具有丰富的外设和通信接口。本文将介绍如何…

前端 JS 经典:动态执行 JS

前言&#xff1a;怎么将字符串当代码执行。有 4 中方式实现 eval、setTimeout、创建 script 标签、new Function 1. eval 特点&#xff1a;同步执行&#xff0c;当前作用域 var name "yq"; function exec(string) {var name "yqcoder";eval(string); …

认识Spring中的BeanFactoryPostProcessor

先看下AI的介绍 在Spring 5.3.x中&#xff0c;BeanFactoryPostProcessor是一个重要的接口&#xff0c;用于在Spring IoC容器实例化任何bean之前&#xff0c;读取bean的定义&#xff08;配置元数据&#xff09;&#xff0c;并可能对其进行修改。以下是关于BeanFactoryPostProce…

【学习笔记】finalshell上传文件夹、上传文件失败或速度为0

出现标题所述的情况&#xff0c;大概率是finalshell上传文件的过程中的权限不够。 可参照&#xff1a;Finalshell上传文件失败或者进度总为百分之零解决方法 如果不成功&#xff0c;建议关闭客户端重试。 同时建议在设置finalshell的ssh连接时根据不同用户设置多个连接&#xf…