go中的context超时控制、超时传递、跨进程超时传递

context包中的WithCancel、WithDeadline和WithTimeout函数提供了创建上下文(context)对象的能力,这些上下文对象对于管理goroutine的生命周期非常重要,尤其是在处理取消、超时和截止时间的场景中。

  1. WithCancel
    WithCancel函数返回一个新的上下文对象和一个取消函数。调用这个取消函数将取消这个上下文对象,以及从它派生的所有上下文对象。

作用与意义
WithCancel用于创建可以被手动取消的上下文。这对于告知goroutine停止当前工作并及时退出非常有用。

代码案例

package mainimport ("context""fmt""time"
)func operation(ctx context.Context, duration time.Duration) {select {case <-time.After(duration):fmt.Println("Operation finished")case <-ctx.Done():fmt.Println("Operation cancelled")}
}func main() {ctx, cancel := context.WithCancel(context.Background())go operation(ctx, 5*time.Second)time.Sleep(2 * time.Second) // 模拟在操作完成前进行取消cancel() // 取消操作// 等待足够长的时间以确保goroutine可以响应取消事件time.Sleep(1 * time.Second)
}
  1. WithDeadline
    WithDeadline函数返回一个新的上下文对象,这个对象会在指定的截止时间自动取消。

作用与意义
WithDeadline用于创建具有明确截止时间的上下文。当达到截止时间时,上下文会自动取消。这对于设置任务的最长执行时间非常有用。

代码案例

package mainimport ("context""fmt""time"
)func main() {deadline := time.Now().Add(3 * time.Second)ctx, cancel := context.WithDeadline(context.Background(), deadline)defer cancel()select {case <-time.After(5 * time.Second):fmt.Println("Operation finished")case <-ctx.Done():fmt.Println("Operation cancelled due to deadline")}
}
  1. WithTimeout
    WithTimeout函数是WithDeadline的便捷版本,它返回一个新的上下文对象,这个对象会在指定的超时时间后自动取消。

作用与意义
WithTimeout用于创建具有超时限制的上下文。当超过超时时间时,上下文会自动取消。这适用于需要限制执行时间的任务。

代码案例

package mainimport ("context""fmt""time"
)func main() {ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)defer cancel()select {case <-time.After(5 * time.Second):fmt.Println("Operation finished")case <-ctx.Done():fmt.Println("Operation cancelled due to timeout")}
}

总结
WithCancel、WithDeadline和WithTimeout是context包中非常重要的函数,它们允许开发者基于取消信号、截止时间和超时控制goroutine的行为。使用这些机制可以让并发程序更加健壮,更容易管理资源和控制goroutine的生命周期。

超时传递
超时传递指的是当一个操作有多个步骤或依赖多个服务时,整个操作的超时设置可以从顶层传递到每个子操作。这样做可以确保整个操作链在给定的超时时间内完成,避免某个子操作耗时过长影响整体性能。

超时传递的代码案例
假设我们有一个任务,它需要依次执行两个步骤,每个步骤都可能耗时,我们希望整个任务在规定的超时时间内完成。

package mainimport ("context""fmt""time"
)func step1(ctx context.Context) error {// 模拟耗时的操作select {case <-ctx.Done():return ctx.Err()case <-time.After(1 * time.Second):fmt.Println("Step 1 completed")return nil}
}func step2(ctx context.Context) error {// 模拟耗时的操作select {case <-ctx.Done():return ctx.Err()case <-time.After(2 * time.Second):fmt.Println("Step 2 completed")return nil}
}func task(ctx context.Context) {// 执行第一步if err := step1(ctx); err != nil {fmt.Println("Task failed:", err)return}// 执行第二步if err := step2(ctx); err != nil {fmt.Println("Task failed:", err)return}fmt.Println("Task completed successfully")
}func main() {// 创建一个总超时时间为3秒的上下文ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)defer cancel()task(ctx)
}

在这个例子中,我们有两个步骤(step1和step2),它们都接受一个上下文对象ctx。这个上下文对象是通过WithTimeout创建的,意味着整个任务有一个总的超时时间限制。每个步骤在执行时都会检查这个上下文对象,以确定是否已经超时或被取消。如果在任一步骤中超时发生,任务将提前终止并报告失败。这个模式确保了超时可以从任务的顶层传递到每个子操作中,使得整个操作链能够响应超时事件。

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

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

相关文章

ubuntu下vscode ctrl+tab松开ctrl后不自动选中文件

vscode用ctrltab切换文件时&#xff0c;松开ctrl键后会自动选中切换的文件。 但是在ubuntu下发现有时不能自动选中切换的文件&#xff0c;需要再次按enter键才能打开文件。 经过测试发现解决方法有两个&#xff1a; 方法1&#xff1a;确认wayland状态&#xff0c;关闭wayland…

基于Spring Boot 3 + Spring Security6 + JWT + Redis实现登录、token身份认证

基于Spring Boot3实现Spring Security6 JWT Redis实现登录、token身份认证。 用户从数据库中获取。使用RESTFul风格的APi进行登录。使用JWT生成token。使用Redis进行登录过期判断。所有的工具类和数据结构在源码中都有。 系列文章指路&#x1f449; 系列文章-基于Vue3创建前端…

MongoDB内存过高问题分析解决

告警 公司有个3.2.7版本的mongo复制集&#xff0c;最近几天频繁告警内存过高。 服务器配置16C64G内存。mongo备节点内存使用到55G&#xff0c;触发告警。 以下内容基于3.2.7版本&#xff0c;3.2.7版本已经太老&#xff0c;很多后来的命令和配置&#xff0c;3.2.7都没有。 …

【黑马头条】-day04自媒体文章审核-阿里云接口-敏感词分析DFA-图像识别OCR-异步调用MQ

文章目录 day4学习内容自媒体文章自动审核今日内容 1 自媒体文章自动审核1.1 审核流程1.2 内容安全第三方接口1.3 引入阿里云内容安全接口1.3.1 添加依赖1.3.2 导入aliyun模块1.3.3 注入Bean测试 2 app端文章保存接口2.1 表结构说明2.2 分布式id2.2.1 分布式id-技术选型2.2.2 雪…

Unity2018发布安卓报错 Exception: Gradle install not valid

Unity2018发布安卓报错 Exception: Gradle install not valid Exception: Gradle install not valid UnityEditor.Android.GradleWrapper.Run (System.String workingdir, System.String task, System.Action1[T] progress) (at <c67d1645d7ce4b76823a39080b82c1d1>:0) …

使用Spring Cloud Gateway构建API网关,实现路由、过滤、流量控制等功能。

使用Spring Cloud Gateway构建API网关&#xff0c;实现路由、过滤、流量控制等功能。 使用Spring Cloud Gateway可以轻松地构建API网关&#xff0c;实现路由、过滤、流量控制等功能。下面是一个简单的示例&#xff0c;演示如何在Spring Boot应用程序中集成Spring Cloud Gatewa…

Prometheus +Grafana +node_exporter可视化监控Linux虚机

1、介绍 待补充 2、架构图 待补充 Prometheus &#xff1a;主要是负责存储、抓取、聚合、查询方面。 node_exporter &#xff1a;主要是负责采集物理机、中间件的信息。 3、搭建过程 配置要求&#xff1a;1台主服务器 n台从服务器 &#xff08;被监控的linux虚机&am…

算法——图论:连通分量数量(深搜,光搜,并查集)

题目&#xff1a;. - 力扣&#xff08;LeetCode&#xff09; 有 n 个城市&#xff0c;其中一些彼此相连&#xff0c;另一些没有相连。如果城市 a 与城市 b 直接相连&#xff0c;且城市 b 与城市 c 直接相连&#xff0c;那么城市 a 与城市 c 间接相连。 省份 是一组直接或间接…

Ubuntu22.04 部署项目常用知识

文件权限 修改owner sudo chown -R username dirpath #dirpath及其子目录owner都将会变成username sudo find /etc/letsencrypt -type d -exec chmod 750 {} \;#-type d: 限制搜索结果只包含目录&#xff08;directory&#xff09; sudo find /etc/letsencrypt -type f -exec…

MoneyPrinterTurbo搭建详细流程(Linux)及常见问题

先附上链接: MoneyPrinterTurbohttps://github.com/harry0703/MoneyPrinterTurboMoneyPrinterTurbo是一款合成视频的软件。 你只需要提供一个主题或者关键字,就可以全自动生成视频文案、视频素材、视频字幕、视频背景音乐,然后合成一个高清的短视频。 接下来讲解详细的搭…

dubbo的服务调用与负载均衡原理、Java如何实现dubbo的服务调用与负载均衡

1、dubbo的服务调用与负载均衡原理 Dubbo是一种分布式服务框架&#xff0c;它支持创建和管理分布式服务&#xff0c;并提供负载均衡的功能。 1、服务调用原理 1.客户端向Dubbo注册中心发起服务调用请求。 2.注册中心根据请求的服务名查找可用的服务提供者列表。 3.注册中心将…

20240328金融读报:国内金融安全网与银行适老化实例

1、国内金融安全网&#xff08;原则&#xff1a;事前防范金融风险过度积累&#xff0c;事中、事后快速高效处置风险&#xff09;&#xff1a;1&#xff09;强化金融机构的公司治理和风险管理&#xff08;如重组与否&#xff09;2&#xff09;二加强金融监管&#xff08;各种存贷…

macOS 13 Ventura (苹果最新系统) v13.6.6正式版

macOS 13 Ventura是苹果电脑的全新操作系统&#xff0c;它为用户带来了众多引人注目的新功能和改进。该系统加强了FaceTime和视频通话的体验&#xff0c;同时优化了邮件、Safari浏览器和日历等内置应用程序&#xff0c;使其更加流畅、快速和安全。特别值得一提的是&#xff0c;…

常用目标检测算法集锦

目标检测算法分类 按照算法流程流程可以分为单阶段和两阶段(two-stage)两种。指的是先通过某种方式生成一些备选框,然后对备选框region proposal中内容进行分类,并修正备选框的位置的方法,由于包含了region proposal和detection两个步骤,故称为two-stage。与之不同的是,…

std::vector与std::map的多线程读写问

参考:https://blog.csdn.net/qq_33726635/article/details/117200332 STL 语义上不提供任何强度的线程安全保证。 1、vector与map都不是线程安全的&#xff1a; 同时读 OK 同时写 NO 同时读写 NO 2、vector读写情况&#xff1a; vector一般情况下同时读写读没问题&#xff0…

测试人进阶技能:单元测试报告应用指南

为什么需要单元测试 从产品角度而言&#xff0c;常规的功能测试、系统测试都是站在产品局部或全局功能进行测试&#xff0c;能够很好地与用户的需要相结合&#xff0c;但是缺乏了对产品研发细节&#xff08;特别是代码细节的理解&#xff09;。 从测试人员角度而言&#xff0…

MySQL索引18连问,谁能顶住

前言 过完这个节&#xff0c;就要进入金银季&#xff0c;准备了 18 道 MySQL 索引题&#xff0c;一定用得上。 作者&#xff1a;感谢每一个支持&#xff1a; github 1. 索引是什么 索引是一种数据结构&#xff0c;用来帮助提升查询和检索数据速度。可以理解为一本书的目录&…

关闭Qt在windows上同时生成debug和release目录

qt在windows下编译&#xff0c;例如选择debug模式&#xff0c;但是会在编译目录下生成两个目录&#xff0c;分别是debug和release&#xff0c;生成的exe放在debug目录下。 进行一个简单的测试&#xff0c;读aaa.txt文件&#xff0c;把他放在跟exe同级目录下&#xff0c;测试代码…

1.linux系统根目录的其他目录的含义(18个目录)

①/bin&#xff1a;存放系统的基本可执行命令&#xff08;二进制文件&#xff09;&#xff0c;如ls、cp、mkdir等。 ②/boot&#xff1a;存放引导加载程序和内核相关文件。 ③/dev&#xff1a;存放设备文件&#xff0c;用于与硬件设备进行通信。 ④/etc&#xff1a;存放系统…

6、jenkins项目构建类型-项目类型介绍

文章目录 一、自由风格项目1、拉取代码2、演示改动代码后的持续集成二、Maven项目构建三、Pipeline流水线项目构建(☆☆☆)1、Pipeline简介(1)概念(2)使用Pipeline有以下好处(3)如何创建Jenkins Pipeline呢?2、安装Pipeline插件3、Pipeline语法快速入门(1)Declarati…