探索C#之storm的TimeCacheMap
作者:网络转载 发布时间:[ 2015/9/17 14:04:36 ] 推荐标签:.NET 算法 测试开发技术
代码执行步骤:
1、初始化桶加入到链表
2、计算缓存数据长过期时间,并作为线程休眠的时间。
3、线程触发时删除后一个桶并加入新的桶
4、不断循环休眠触发触发
5、启动线程
整个桶的数据删除只需要加一次锁即可,保证其高效。
获取、插入、删除
遍历整个链表,查询到第一个满足key的立即返回,这需要保证不会有重复key。
public V Get(K key)
{
lock (Obj)
{
foreach (var item in buckets)
{
if (item.ContainsKey(key))
return item[key];
}
return default(V);
}
}
在插入时删除对应的key,保证不会有重复的key出现。
public void Put(K key, V value)
{
lock (Obj)
{
foreach (var item in buckets)
{
item.Remove(key);
}
buckets.First().Add(key, value);
}
}
删除对应的key
public void Remove(K key)
{
lock (Obj)
{
foreach (var item in buckets)
{
if (item.ContainsKey(key))
item.Remove(key);
}
}
}
总结
在那些年我们一起追过的缓存写法(三)中有介绍过关于惰性删除及高效LRU算法优化缓存容器的过期,有兴趣的童鞋可以看看。
完整代码中有容器Size、ContainsKey的实现,github-TimeCacheMap.c#。
在storm中,spout发射的消息和acker的消息即保存在各自的TimeCacheMap里,如果消息超时后会自动通知spout的fail方法。 在storm0.8后TimeCacheMap被弃用了,使用的是新的RotatingMap,但设计和实现基本没变,github-TimeCacheMap.java及github-RotatingMap.java。
本文内容不用于商业目的,如涉及知识产权问题,请权利人联系SPASVO小编(021-61079698-8054),我们将立即处理,马上删除。
相关推荐
更新发布
功能测试和接口测试的区别
2023/3/23 14:23:39如何写好测试用例文档
2023/3/22 16:17:39常用的选择回归测试的方式有哪些?
2022/6/14 16:14:27测试流程中需要重点把关几个过程?
2021/10/18 15:37:44性能测试的七种方法
2021/9/17 15:19:29全链路压测优化思路
2021/9/14 15:42:25性能测试流程浅谈
2021/5/28 17:25:47常见的APP性能测试指标
2021/5/8 17:01:11热门文章
常见的移动App Bug??崩溃的测试用例设计如何用Jmeter做压力测试QC使用说明APP压力测试入门教程移动app测试中的主要问题jenkins+testng+ant+webdriver持续集成测试使用JMeter进行HTTP负载测试Selenium 2.0 WebDriver 使用指南