博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Go 采用 time.After 实现超时控制
阅读量:5879 次
发布时间:2019-06-19

本文共 1006 字,大约阅读时间需要 3 分钟。

场景:

假设业务中需调用服务接口A,要求超时时间为5秒,那么如何优雅、简洁的实现呢?

我们可以采用select+time.After的方式,十分简单适用的实现。

首先,我们先看time.After()源码:

// After waits for the duration to elapse and then sends the current time// on the returned channel.// It is equivalent to NewTimer(d).C.// The underlying Timer is not recovered by the garbage collector// until the timer fires. If efficiency is a concern, use NewTimer// instead and call Timer.Stop if the timer is no longer needed.func After(d Duration) <-chan Time {    return NewTimer(d).C}

time.After()表示time.Duration长的时候后返回一条time.Time类型的通道消息。那么,基于这个函数,就相当于实现了定时器,且是无阻塞的。

超时控制的代码实现:

package mainimport (    "time"    "fmt")func main() {    ch := make(chan string)    go func() {        time.Sleep(time.Second * 2)        ch <- "result"    }()    select {    case res := <-ch:        fmt.Println(res)    case <-time.After(time.Second * 1):        fmt.Println("timeout")    }}

我们使用channel来接收协程里的业务返回值。

select语句阻塞等待最先返回数据的channel,当先接收到time.After的通道数据时,select则会停止阻塞并执行该case的代码。此时就已经实现了对业务代码的超时处理。

原文地址:

转载地址:http://occix.baihongyu.com/

你可能感兴趣的文章
MVC和MTV结构分析
查看>>
(转)微信网页扫码登录的实现
查看>>
SpringBoot2.x配置Cors跨域
查看>>
用AJAX实现页面登陆以及注册用户名验证
查看>>
mariadb启动报错:[ERROR] Can't start server : Bind on unix socket: Permission denied
查看>>
nginx的信号量
查看>>
30分钟新手git教程
查看>>
passwd的使用
查看>>
最爱的小工具,谁用谁知道!
查看>>
EntityFramework之一对一关系(二)
查看>>
获取表的信息,包含字段的描述
查看>>
Mybatis学习
查看>>
C# 的关键字系列 (2 of n)
查看>>
runtime第三部分方法和消息
查看>>
C# Enum,Int,String的互相转换 枚举转换
查看>>
python 数值系列-进制转换
查看>>
预测和交易大型股票指数的高频波动率
查看>>
在既定状态下截图
查看>>
JAVA android 点击两次返回键退出
查看>>
JAVA入门到精通-第42讲-坦克大战9
查看>>