伏龙阁资源网

golang模拟实现带超时的信号量示例代码
站长资源 2024/11/22 佚名
2 0

前言

最近在写项目，需要用到信号量等待一些资源完成，但是最多等待N毫秒。在看本文的正文之前，我们先来看下C语言里的实现方法。

在C语言里，有如下的API来实现带超时的信号量等待：

SYNOPSIS
  #include <pthread.h>
 
  int
  pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex, const struct timespec *abstime);

然后在查看golang的document后，发现golang里并没有实现带超时的信号量，官方文档在这里。

原理

我的业务场景是这样的：我有一个缓存字典，当多个用户请求1个不存在的key时，只有1个请求会穿透到后端，而所有用户都要排队等这个请求完成，或者超时返回。

怎么实现呢？其实稍微想一想cond的原理，就能模拟一个带超时的cond出来。

在golang里，要同时实现”挂起等待”和”超时返回”，一般得用select case语法，一个case等待阻塞的资源，一个case等待一个timer，这一点是非常确定的。

原本阻塞的资源应该通过条件变量的机制来实现完成通知，既然这里决定用select case，那么自然想到用channel来代替这个完成通知。

接下来的问题就是，很多请求者并发来获取这个资源，但是资源还没有准备好，所以大家都要排队并挂起，等待资源完成，并且当资源完成后通知大家。

所以，这里很自然要为这个资源做一个队列，每个请求者创建一个chan，并将chan放到队列里，接着select case等待这个chan的通知。而另一端，资源完成后遍历队列，通知每个chan即可。

最后一个问题是，只有第一个请求者才能穿透请求到后端，而后续请求者不应该穿透重复的请求，这可以通过判断缓存里是否有这个key作为判定首次的条件，而标记位init来判断请求者是否应该排队。

我的场景

上面是思路，下面是我的业务场景实现。

func (cache *Cache) Get(key string, keyType int) *string {
 if keyType == KEY_TYPE_DOMAIN {
 key = "#" + key
 } else {
 key = "=" + key
 }
 
 cache.mutex.Lock()
 item, existed := cache.dict[key]
 if !existed {
 item = &cacheItem{}
 item.key = &key
 item.waitQueue = list.New()
 cache.dict[key] = item
 }
 cache.mutex.Unlock()
 
 conf := config.GetConfig()
 
 lastGet := getCurMs()
 
 item.mutex.Lock()
 item.lastGet = lastGet
 if item.init { // 已存在并且初始化
 defer item.mutex.Unlock()
 return item.value
 }
 
 // 未初始化，排队等待结果
 wait := waitItem{}
 wait.wait_chan = make(chan *string, 1)
 item.waitQueue.PushBack(&wait)
 item.mutex.Unlock()
 
 // 新增key, 启动goroutine获取初始值
 if !existed {
 go cache.initCacheItem(item, keyType)
 }
 
 timer := time.NewTimer(time.Duration(conf.Cache_waitTime) * time.Millisecond)
 
 var retval *string = nil
 
 // 等待初始化完成
 select {
 case retval = <- wait.wait_chan:
 case <- timer.C:
 }
 return retval
}

简述一下整个过程：

  • 首先锁字典，如果key不存在，说明我是第一个请求者，我会创建这个key对应的value，只不过init=false表示它正在初始化。最后，释放字典锁。
  • 接下来，锁住这个key，判断它已经初始化完成，那么直接返回value。否则，创建一个chan放入waitQueue等待队列。最后，释放key锁。
  • 接着，如果当前是第一个请求者，那么会穿透请求到后端（在一个独立的协程里去发起网络调用）。
  • 现在，创建一个用于超时的定时器。
  • 最后，无论当前是否是key的第一个请求者，还是初始化期间的并发请求者，它们都通过select case超时的等待结果完成。

在initCacheItem函数里，数据已获取成功

 // 一旦标记为init, 后续请求将不再操作waitQueue
 item.mutex.Lock()
 item.value = newValue
 item.init = true
 item.expire = expire
 item.mutex.Unlock()
 
 // 唤醒所有排队者
 waitQueue := item.waitQueue
 for elem := waitQueue.Front(); elem != nil; elem = waitQueue.Front() {
 wait := elem.Value.(*waitItem)
 wait.wait_chan <- newValue
 waitQueue.Remove(elem)
 }
  • 首先，锁住key，标记init=true，并赋值value，并释放锁。此后的请求，都可以立即返回，无需排队。
  • 之后，因为init=true已被标记，此刻再也有没有请求会修改waitQueue，所以无需加锁，直接遍历队列，通知其中的每个chan。

最后

这样就实现了带超时的条件变量效果，实际上我的场景是一个broadcast的cond例子，大家可以参照思路实现自己想要的效果，活学活用。

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对的支持。

广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！
www.wwsws.com 伏龙阁资源网
39,976影音资源
44,792技术资源
21,817软件资源
651,128站长资源

更新日志

友情链接

杰晶网络 DDR爱好者之家 桃源资源网 杰网资源 富贵资源网 南强小屋 铁雪资源网 幽灵资源网 万梅资源网 狼山资源网 白云岛资源网 昆仑资源网 相思资源网 明霞山资源网 内蒙古资源网 黑松山资源网 茶园资源网 饿虎岗资源网 大旗谷资源网 常春岛资源网 岱庙资源网 兴国资源网 快活林资源网 蝙蝠岛资源网 帝王谷资源网 白云城资源网 伏龙阁资源网 清风细雨楼 天枫庄资源网 圆月山庄资源网 无争山庄资源网 神水资源网 移花宫资源网 神剑山庄资源网 无为清净楼资源网 金钱帮资源网 丐帮资源网 华山资源网 极乐门资源网 小李飞刀资源网 凤求凰客栈 风云阁资源网 金狮镖局 鸳鸯亭资源网 千金楼资源网 更多链接