【Golang 面试 - 进阶题】每日 3 题(三)

✍个人博客:Pandaconda-CSDN博客

📣专栏地址:http://t.csdnimg.cn/UWz06

📚专栏简介:在这个专栏中,我将会分享 Golang 面试中常见的面试题给大家~
❤️如果有收获的话,欢迎点赞👍收藏📁,您的支持就是我创作的最大动力💪

13. Cond 中 Wai t 使用

在 Go 语言中,sync.Cond 类型提供了 Wait() 方法来让 Goroutine 等待条件变量。当 Goroutine 调用 Wait() 方法时,它会释放已经持有的锁,并阻塞在条件变量上,直到另一个 Goroutine 调用 Signal()Broadcast() 方法,并释放锁,唤醒了它。被唤醒的 Goroutine 会重新尝试获得锁,然后继续执行。

下面是一个使用 sync.CondWait() 方法的示例:

package main
import ("fmt""sync""time"
)
func main() {var mutex sync.Mutexcond := sync.NewCond(&mutex)ready := falsego func() {time.Sleep(time.Second * 1)mutex.Lock()ready = truecond.Signal()mutex.Unlock()}()mutex.Lock()for !ready {cond.Wait()}mutex.Unlock()fmt.Println("Goroutine is ready")
}

在这个例子中,我们首先创建了一个 sync.Mutex 实例和一个与之关联的 sync.Cond 实例。我们在一个 Goroutine 中等待 1 秒钟,然后发送一个 Signal() 信号来唤醒等待条件变量的 Goroutine。在主 Goroutine 中,我们首先获取了锁,然后开始等待条件变量。在等待过程中,Goroutine 会释放锁并阻塞在条件变量上,直到另一个 Goroutine 发送了 Signal() 信号并唤醒了它。被唤醒的 Goroutine 会重新尝试获取锁,并在获取到锁后输出一条消息。

需要注意的是,调用 Wait() 方法之前必须先获取锁,否则会出现死锁等问题。另外,在使用 Wait() 方法时,要确保有其他 Goroutine 会发送 Signal()Broadcast() 信号,否则可能会导致 Goroutine 永久阻塞。

14. W aitGroup 用法

在 Go 语言中,sync.WaitGroup 类型提供了一种方便的方式来等待多个 Goroutine 完成它们的任务。WaitGroup 可以被用来跟踪一组 Goroutine,等待它们完成任务并汇总结果。下面是 WaitGroup 的基本用法示例:

package main
import ("fmt""sync"
)
func main() {var wg sync.WaitGroupfor i := 0; i < 5; i++ {wg.Add(1)go func(i int) {fmt.Printf("Goroutine %d\n", i)wg.Done()}(i)}wg.Wait()fmt.Println("All Goroutines are done")
}

在这个示例中,我们首先创建了一个 sync.WaitGroup 实例。然后,在一个 for 循环中创建了 5 个 Goroutine,并调用 wg.Add(1) 方法将计数器加 1,表示有一个 Goroutine 需要等待。在每个 Goroutine 中,我们输出了一条消息,表示该 Goroutine 正在执行任务,并调用 wg.Done() 方法将计数器减 1,表示该 Goroutine 已经完成任务。最后,我们调用 wg.Wait() 方法等待所有 Goroutine 完成任务,然后输出一条消息表示所有 Goroutine 都已完成。

需要注意的是,调用 Add() 方法之后必须调用 Done() 方法,否则会出现死锁等问题。另外,在等待所有 Goroutine 完成任务时,要确保所有 Goroutine 都已经调用了 Done() 方法,否则可能会导致程序永久阻塞。

WaitGroup 还提供了一个 WaitGroup.Add() 方法,可以将计数器增加指定的值,以便一次性添加多个需要等待的 Goroutine。另外,WaitGroup 还支持嵌套使用,即在一个 Goroutine 中使用 WaitGroup 等待一组 Goroutine 完成任务,并在另一个 WaitGroup 中使用这个 Goroutine 作为一项任务等待其他 Goroutine 完成任务。

15. WaitGroup 实现原理

在 Go 语言中,sync.WaitGroup 的实现原理非常简单,它基本上是通过一个计数器来实现的。当我们调用 WaitGroup.Add(n) 方法时,它会将计数器的值增加 n。当我们调用 WaitGroup.Done() 方法时,它会将计数器的值减 1。而当我们调用 WaitGroup.Wait() 方法时,它会阻塞等待,直到计数器的值为 0。

下面是 sync.WaitGroup 的简化版实现,用来更好地理解它的工作原理:

type WaitGroup struct {counter int32cond    *sync.Cond
}
func NewWaitGroup() *WaitGroup {return &WaitGroup{counter: 0,cond:    sync.NewCond(&sync.Mutex{}),}
}
func (wg *WaitGroup) Add(delta int) {atomic.AddInt32(&wg.counter, int32(delta))
}
func (wg *WaitGroup) Done() {atomic.AddInt32(&wg.counter, -1)if wg.counter == 0 {wg.cond.Broadcast()}
}
func (wg *WaitGroup) Wait() {wg.cond.L.Lock()for wg.counter > 0 {wg.cond.Wait()}wg.cond.L.Unlock()
}

在这个简化版实现中,我们首先创建了一个 WaitGroup 类型,并将计数器初始化为 0。然后,我们使用 sync.Cond 类型来实现等待和通知机制,以便在调用 Wait() 方法时可以阻塞等待。

Add() 方法中,我们使用原子操作将计数器的值增加指定的值。在 Done() 方法中,我们使用原子操作将计数器的值减 1,并检查计数器是否为 0。如果计数器为 0,说明所有 Goroutine 都已经完成任务,我们就可以使用 sync.Cond.Broadcast() 方法通知所有正在等待的 Goroutine 继续执行。

Wait() 方法中,我们首先获取互斥锁,然后在一个循环中等待计数器的值为 0。在循环中,我们使用 sync.Cond.Wait() 方法释放互斥锁,并等待条件变量上的通知。当计数器的值为 0 时,说明所有 Goroutine 都已经完成任务,我们就可以退出循环,并释放互斥锁。

需要注意的是,这个简化版实现并没有考虑到 WaitGroup 的嵌套使用情况,并且也没有处理 WaitGroup 计数器被减为负数的情况。真正的 sync.WaitGroup 实现要比这个简化版实现复杂得多,但是基本的实现原理是一样的。

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

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

相关文章

web基础及http协议、

⼀、web基本概念和常识 Web&#xff1a;为⽤户提供的⼀种在互联⽹上浏览信息的服务&#xff0c;Web 服 务是动态的、可交 互的、跨平台的和图形化的。Web 服务为⽤户提供各种互联⽹服务&#xff0c;这些服务包括信息浏览 服务&#xff0c;以及各种交互式服务&#xff0c;包括聊…

芋道微服务全栈开发日记(商品sku数据归类为规格属性)

商品的每一条规格和属性在数据库里都是单一的一条数据&#xff0c;从数据库里查出来后&#xff0c;该怎么归类为对应的规格和属性值&#xff1f;如下图&#xff1a; 在商城模块&#xff0c;商品的单规格、多规格、单属性、多属性功能可以说是非常完整&#xff0c;如下图&#x…

web、http协议、apache服务、nginx服务

web基本概念和常识 概念 web&#xff1a;为用户提供的一种在互联网上浏览信息的服务&#xff0c;是动态的、可交互的、跨平台的和图形化的&#xff1b; 为用户提供各种互联网服务&#xff0c;这些服务包括浏览服务以及各种交互式服务&#xff0c;包括聊天、购物等&#xff1…

Arpg 游戏 对象实体 entity(二)

设计一个 entity class&#xff0c;用于创建和管理游戏世界中的实体对象。这个类包含了大量的函数&#xff0c;用于处理实体的各种行为和属性&#xff0c;例如创建、移动、播放动画、同步状态等。 CreateTitle 函数的作用是创建和初始化一个实体的标题显示。在游戏或模拟程序中…

shp格式数据详解

还是大剑师兰特&#xff1a;曾是美国某知名大学计算机专业研究生&#xff0c;现为航空航海领域高级前端工程师&#xff1b;CSDN知名博主&#xff0c;GIS领域优质创作者&#xff0c;深耕openlayers、leaflet、mapbox、cesium&#xff0c;canvas&#xff0c;webgl&#xff0c;ech…

MATLAB中“varargin”的作用

varargin是什么&#xff1f; 在MATLAB中&#xff0c;varargin是一个特殊的变量&#xff0c;用于接收函数输入参数中的可变数量的参数。它允许用户在调用函数时传递不确定数量的参数。 varargin的本质是一个包含了所有可变参数的cell数组。在函数内部&#xff0c;可以使用cell…

javascript 判断是否为数字

javascript 判断是否为数字 function isNumberTest(str) {const method1 (v) > {let exp /^[-]?\d*(\.\d*)?(e[-]?\d)?$/;// exp.test("1.9"); // true// exp.test("-.1e11"); // truereturn exp.test(v) && str ! "";};con…

鸿蒙HarmonyOS开发:@Observed装饰器和@ObjectLink装饰器:嵌套类对象属性变化

文章目录 一、装饰器二、概述三、限制条件四、装饰器说明五、Toggle组件1、子组件2、接口3、ToggleType枚举4、事件 六、示例演示1、代码2、效果 一、装饰器 State装饰器&#xff1a;组件内状态Prop装饰器&#xff1a;父子单向同步Link装饰器&#xff1a;父子双向同步Provide装…

.NET周刊【7月第4期 2024-07-28】

国内文章 .NET 高性能缓冲队列实现 BufferQueue https://mp.weixin.qq.com/s/fUhJpyPqwcmb3whuV3CDyg BufferQueue 是一个用 .NET 编写的高性能的缓冲队列实现&#xff0c;支持多线程并发操作。 项目地址&#xff1a;https://github.com/eventhorizon-cli/BufferQueue 项目…

计算机网络面试题2

WebSocket相关知识 什么是WebSocket? WebSocket是一种基于TCP连接的全双工通信协议&#xff0c;即客户端和服务器可以同时发送和接收数据 WebSocket和HTTP有什么区别&#xff1f; 1.WebSocket是双向通信协议&#xff0c;HTTP是单向通信协议 2.WebSocket使用ws://或者wss:/…

【Python】基础学习技能提升代码样例6:日志logging

logging 模块实现了python的日志能力。本文通过几个示例展示一些重点概念与用法。 一、线程安全介绍 logging 模块的目标是使客户端不必执行任何特殊操作即可确保线程安全。 它通过使用线程锁来达成这个目标&#xff1b;用一个锁来序列化对模块共享数据的访问&#xff0c;并且…

upload-labs靶场练习

文件上传函数的常见函数&#xff1a; 在PHP中&#xff0c;‌文件上传涉及的主要函数包括move_uploaded_file(), is_uploaded_file(), get_file_extension(), 和 mkdir()。‌这些函数共同协作&#xff0c;‌使得用户可以通过HTTP POST方法上传文件&#xff0c;‌并在服务器上保存…

【RabbitMQ】RabbitMQ概述

一、简介 RabbitMQ是一个开源的消息代理&#xff08;Message Broker&#xff09;系统&#xff0c;最初由Rabbit Technologies Ltd开发&#xff0c;并在开源社区的支持下不断发展和完善。它实现了AMQP&#xff08;高级消息队列协议&#xff09;&#xff0c;为分布式系统和应用提…

实战:安装ElasticSearch 和常用操作命令

概叙 科普文&#xff1a;深入理解ElasticSearch体系结构-CSDN博客 Elasticsearch各版本比较 ElasticSearch 单点安装 1 创建普通用户 #1 创建普通用户名&#xff0c;密码 [roothlink1 lyz]# useradd lyz [roothlink1 lyz]# passwd lyz#2 然后 关闭xshell 重新登录 ip 地址…

kaggle使用api下载数据集

背景 kaggle通过api并配置代理下载数据集datasets 步骤 获取api key 登录kaggle&#xff0c;点个人资料&#xff0c;获取到自己的api key 创建好的key会自动下载 将key放至家目录下的kaggle.json文件中 我这里是windows的administrator用户。 装包 我用了虚拟环境 pip …

Vite + Vue3 + TS项目配置前置路由守卫

在现代前端开发中&#xff0c;使用 Vue 3 和 TypeScript 的组合是一种流行且高效的开发方式。Vite 是一个极速的构建工具&#xff0c;可以显著提升开发体验。本文博主将指导你如何在 Vite Vue 3 TypeScript 项目中配置前置路由守卫&#xff08;Navigation Guards&#xff09;…

【YashanDB知识库】如何远程连接、使用YashanDB?

问题现象 在各个项目实施中&#xff0c;我们经常遇到客户、开发人员需要连接和使用YashanDB但不知如何操作的问题&#xff0c;本文旨在介绍远程连接、使用YashanDB的几种方式。 问题的风险及影响 无风险 问题影响的版本 历史版本~23.2 问题发生原因 无 解决方法及规避方…

TCP请求如何获取客户端真实源IP地址

应用场景 在基于TCP的应用程序中&#xff0c;获取客户端真实源IP地址可以用于以下应用场景&#xff1a; 访问控制和安全策略&#xff1a;通过获取客户端真实源IP地址&#xff0c;应用程序可以实施访问控制策略&#xff0c;限制或允许特定IP地址的访问。这可以用于身份验证、防…

前端web开发HTML+CSS3+移动web(0基础,超详细)——第1天

一、开发坏境的准备 1&#xff0c;在微软商店下载并安装VS Code 以及谷歌浏览器或者其他浏览器&#xff08;我这里使用的是Microsoft Edge&#xff09; 2&#xff0c;打开vs code &#xff0c;在电脑桌面新建一个文件夹命名为code&#xff0c;将文件夹拖拽到vs code 中的右边…

Windows10安装CMake图文教程

CMake是一个跨平台的开源构建工具&#xff0c;用于管理软件构建过程。CMake允许开发人员使用简单的语法来描述项目的构建过程&#xff0c;而无需直接处理特定于操作系统或编译器的细节。开发人员可以编写CMakeLists.txt文件来指定项目的源文件、依赖项和构建规则&#xff0c;然…