前言

最近在写项目,需要用到信号量等待一些资源完成,但是最多等待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
}
简述一下整个过程:
在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)
}
最后
这样就实现了带超时的条件变量效果,实际上我的场景是一个broadcast的cond例子,大家可以参照思路实现自己想要的效果,活学活用。
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对的支持。
# golang
# 信号量
# 超时
# Golang中的信号(Signal)机制详解
# 拦截信号Golang应用优雅关闭的操作方法
# Golang信号量设计实现示例详解
# golang 监听服务的信号
# 实现平滑启动
# linux信号说明详解
# golang使用信号量热更新的实现示例
# Golang信号处理及如何实现进程的优雅退出详解
# Golang信号处理实战
# 第一个
# 请求者
# 创建一个
# 都要
# 遍历
# 后端
# 不存在
# 来实现
# 锁住
# 挂起
# 是一个
# 我是
# 还没有
# 在这里
# 完成后
# 我会
# 就能
# 首次
# 多个
相关文章:
武汉网站设计制作公司,武汉有哪些比较大的同城网站或论坛,就是里面都是武汉人的?
网站制作员失业,怎样查看自己网站的注册者?
如何选择高效可靠的多用户建站源码资源?
Swift中swift中的switch 语句
如何续费美橙建站之星域名及服务?
如何用手机制作网站和网页,手机移动端的网站能制作成中英双语的吗?
如何在建站之星网店版论坛获取技术支持?
建站之星安装路径如何正确选择及配置?
手机钓鱼网站怎么制作视频,怎样拦截钓鱼网站。怎么办?
建站之星IIS配置教程:代码生成技巧与站点搭建指南
如何在建站主机中优化服务器配置?
如何在阿里云ECS服务器部署织梦CMS网站?
网站制作多少钱一个,建一个论坛网站大约需要多少钱?
简易网站制作视频教程,使用记事本编写一个简单的网页html文件?
阿里云网站制作公司,阿里云快速搭建网站好用吗?
东莞专业制作网站的公司,东莞大学生网的网址是什么?
齐河建站公司:营销型网站建设与SEO优化双核驱动策略
如何解决ASP生成WAP建站中文乱码问题?
如何快速上传自定义模板至建站之星?
安徽网站建设与外贸建站服务专业定制方案
如何在Ubuntu系统下快速搭建WordPress个人网站?
如何确认建站备案号应放置的具体位置?
网站设计制作书签怎么做,怎样将网页添加到书签/主页书签/桌面?
如何在阿里云通过域名搭建网站?
如何通过万网虚拟主机快速搭建网站?
如何在Mac上搭建Golang开发环境_使用Homebrew安装和管理Go版本
济南网站建设制作公司,室内设计网站一般都有哪些功能?
如何获取开源自助建站系统免费下载链接?
如何在橙子建站上传落地页?操作指南详解
深圳网站制作培训,深圳哪些招聘网站比较好?
郑州企业网站制作公司,郑州招聘网站有哪些?
建站之星在线客服如何快速接入解答?
红河网站制作公司,红河事业单位身份证如何上传?
深入理解Android中的xmlns:tools属性
零服务器AI建站解决方案:快速部署与云端平台低成本实践
专业网站建设制作报价,网页设计制作要考什么证?
大学网站设计制作软件有哪些,如何将网站制作成自己app?
在线ppt制作网站有哪些,请推荐几个好的课件下载的网站?
油猴 教程,油猴搜脚本为什么会网页无法显示?
如何快速搭建二级域名独立网站?
杭州银行网站设计制作流程,杭州银行怎么开通认证方式?
打鱼网站制作软件,波克捕鱼官方号怎么注册?
黑客入侵网站服务器的常见手法有哪些?
非常酷的网站设计制作软件,酷培ai教育官方网站?
如何在新浪SAE免费搭建个人博客?
如何获取PHP WAP自助建站系统源码?
品牌网站制作公司有哪些,买正品品牌一般去哪个网站买?
完全自定义免费建站平台:主题模板在线生成一站式服务
建站之星好吗?新手能否轻松上手建站?
深圳网站制作平台,深圳市做网站好的公司有哪些?
*请认真填写需求信息,我们会在24小时内与您取得联系。