GoResiliency库中timeout实现原理及源码解析

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《GoResiliency库中timeout实现原理及源码解析》，以下内容将会涉及到Resiliency、timeout，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

1.go-resiliency简介

​ 今天看到项目里用到了go-resiliency这个库，库整体比较简单，代码量不大。主要实现go中几种常见的模式：

后面分析下这几种模式的实现

- circuit-breaker 熔断器
- semaphore       信号量
- timeout         函数超时
- batching        批处理
- retriable       可重复

2.timeout模式

先看看模式的test用例

import (
	"errors"
	"testing"
	"time"
)
func takesFiveSecond(stopper 

• 这里先dl := New(10 * time.Second)创建timeout对象Deadline，可以看到Deadline只有一个变量，就是超时时间。
• 执行函数调用dl.Run(takesFiveSecond)，如果调用的函数执行时间大于变量timeout，会返回失败。

3.源码实现如下

type Deadline struct {
	timeout time.Duration
}
func New(timeout time.Duration) *Deadline {
	return &Deadline{
		timeout: timeout,
	}
}

Deadline对象只有一个timeout成员变量

Run核心函数：

//1. 可以看到Run函数有一个入参是一个函数，函数的原型为func (

Run函数定义：Run(work func(

• 可以看到Run函数有一个入参是一个函数，函数的原型为func (
• Run函数返回error，这个返回实际是入参work函数返回的。

4.扩展一下

go语言里超时控制还有其他常用方式吗

对就是context.WithTimeout，让我们使用context.WithTimeout来重新实现上面的对象,只需要修改一个地方

import (
	"context"
	"errors"
	"time"
)
var ErrTimedOut = errors.New("timed out waiting for function to finish")
type ContextTimeOut struct {
	timeout time.Duration
}
// New constructs a new Deadline with the given timeout.
func New(timeout time.Duration) *ContextTimeOut {
	return &ContextTimeOut{
		timeout: timeout,
	}
}
func (d *ContextTimeOut) Run(work func(

到这里，我们也就讲完了《GoResiliency库中timeout实现原理及源码解析》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于golang的知识点！