Go语言利用time.After实现超时控制的方法详解
2018-08-22 08:27
881 查看
前言
在开始之前,对time.After使用有疑问的朋友们可以看看这篇文章:https://www.jb51.nethttps://www.geek-share.com/detail/2745899624.html
我们在Golang网络编程中,经常要遇到设置超时的需求,本文就来给大家详细介绍了Go语言利用time.After实现超时控制的相关内容,下面话不多说了,来一起看看详细的介绍吧。
场景:
假设业务中需调用服务接口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 main import ( "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的代码。此时就已经实现了对业务代码的超时处理。
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对脚本之家的支持。
您可能感兴趣的文章:
相关文章推荐
- go语言中sort包的实现方法与应用详解
- linux下利用gsoap实现webservice通信方法详解
- syncOnce的Go语言与C++11实现方法
- go语言实现sqrt的方法
- struts2利用异常处理实现权限控制的两种方法
- Redhat服务器利用rsync和inotify-tools实现实时增量备份的方法(详解)
- go语言实现文件分割的方法
- 如何利用Guava实现方法调用超时自动中断
- go语言channel实现多核并行化运行的方法
- Go语言中io.Reader和io.Writer的详解与实现
- 一种利用线程池线程执行任务, 并能够结束超时任务的方法 (.NET实现)
- java利用线程池(ExecutorService)配合Callable和Future实现执行方法超时的阻断
- go语言实现AES加密的方法
- Go语言实现简单Web服务器的方法
- Go语言中通过结构体匿名字段实现方法的继承和重载
- c#之利用API函数实现动画窗体的方法详解
- Go语言中的方法、接口和嵌入类型详解
- go语言实现猜数字小游戏的方法
- Go语言使用组合的方式实现多继承的方法