java环形队列_使用环形队列触发延时任务
类似需求:“如果连续30s没有请求包(例如登录,消息,keepalive包),服务端就要将这个用户的状态置为离线”。
轮询处理
将所有任务都添加到某集合中,定时轮询扫描,如果达到条件则进行相关处理;
let map = new Map();
function doAction(uid) {
map.set(uid, new Date().getTime());
}
setInterval(function(){
for(let uid of map.keys()) {
if(+new Date() - map.get(uid) > 30000) {
map.delete(uid);
console.log(`${uid}超过30s未做任何操作,设置为离线!`);
}
}
}, 10000);
方案的不足:
效率低下。已经被执行过记录,仍然会被扫描(只是不会出现在结果集中),存在大量的重复计算;
时效性差。时间误差取决于轮询的间隔;如果间隔过小,重复被扫描的次数更高,效率会变得更低下。
定时处理
每来一个任务,启动一个定时器,达到定时器时间,执行相关处理;
function doAction(uid) {
map.set(uid, new Date().getTime());
setTimeout(function() {
console.log(`${uid}超过30s未做任何操作,设置为离线!`);
}, 30000);
}
方案的不足:
任务过多时占用内存过大
环形队列处理
数据结构:
环形队列ListLoop,例如可以创建一个包含0-30的slot环形队列(本质是个数组)(30s超时);
每个环上的任务集合Slot,环上每一个slot是一个Set;
记录每个Task对应落到Slot的Map集合;
执行过程:
**第一步:**启动一个timer,每隔1s,在上述环形队列中移动一格,0->1->2->3…->29->30->0…有一个CurrentSlotIndex指针来标识刚检测过的slot ;
**第二步:**当有某用户uid有请求包到达时,从Map结构中,查找出这个uid存储在哪一个slot里;
**第三步:**如果存在,从这个slot的Set结构中,删除这个uid,否则跳过该步骤;
**第四步:**将uid重新加入到新的slot中(CurrentSlotIndex指针所指向的上一个slot)因为这个slot,会被timer在30s之后扫描到
**第五步:**更新Map,重新设置该uid对应slot的index值
// new Array(31).fill(new Set())
// No,数组中所有Set集合为同一个
let listLoop = new Array(31),
map = new Map(), // 记录每个uid的slotIndex
currentSlotIndex = 1; // 当前要检测的slot
function doAction(uid) {
// 如果循环队列中已存在该uid,需要先干掉,重新计时
let slotIndex = map.get(uid);
slotIndex && listLoop[slotIndex].delete(uid);
// 将该uid重现添加到循环队列中
// 周期31,新插入的置入当前的后一个(即,30s后可以扫描到它)
// 更新map中这个uid的最新slotIndex
slotIndex = currentSlotIndex - 1;
listLoop[slotIndex] = listLoop[slotIndex] ?
listLoop[slotIndex].add(uid) : new Set().add(uid);
map.set(uid, slotIndex);
}
// 每秒钟移动一个slot,这个slot对应的set集合中所有uid都为超时
// 如果所有slot对应的set集合都为空,则表示没有uid超时
setInterval(function() {
var slotSet = listLoop[currentSlotIndex];
if(slotSet && slotSet.size > 0) {
for(let uid of slotSet.values()) {
// 执行完的uid从map集合中剔除
map.delete(uid);
console.log(`超过30s未做任何操作,设置为离线!`);
}
// 置空该集合
slotSet.clear();
}
// 指标继续+1
currentSlotIndex = (++currentSlotIndex) % 31;
}, 1000);
// 思路、注意Map集合的内心移除情况。
方案的优点:
无需再轮询全部订单,效率高
无重复执行,一个订单,任务只执行一次
效性好,精确到秒(控制timer移动频率可以控制精度)
举一反三
上述展示描述了一种业务场景,通过环形队列的方式我们还可以处理很多类似场景。
某打车软件订单完成后,如果用户一直不评价,48小时后会将自动评价为5星;
某数据产品用户修改设置,1小时后生效;
…
转载至链接:https://my.oschina.net/ahaoboy/blog/1794761
java环形队列_使用环形队列触发延时任务相关推荐
- java栈和队列_栈和队列的面试题Java
栈和队列: 面试的时候,栈和队列经常会成对出现来考察.本文包含栈和队列的如下考试内容: (1)栈的创建 (2)队列的创建 (3)两个栈实现一个队列 (4)两个队列实现一个栈 (5)设计含最小函数min ...
- java mq 积压_解决消息队列的数据积压只需这三招
点击上方 "Java架构师社区"关注我们,设为星标 回复"架构师"获取资源 1 概述 最近生产环境的消息通知队列发生了大量的数据积压问题,从而影响到整个平台商户 ...
- java怎么遍历优先级队列_打印优先级队列的内容[java]
如何使print_queue在Java中正常工作?这是我自己的队列实现. 使用Iterator()可以正常工作,除了它会以随机顺序打印数字. package data_structures_java ...
- java抢单功能_基于消息队列的高并发抢单功能实现方法与流程
本发明涉及嵌入式软件中间件,具体涉及一种基于消息队列的高并发抢单功能实现方法. 背景技术: 中间件是一种独立的系统软件或服务程序,分布式应用系统借助这种软件在不同的技术之间共享资源,管理计算资源和网络 ...
- JAVA线程池_并发队列工作笔记0001---认识阻塞队列_非阻塞队列
技术交流QQ群[JAVA,C++,Python,.NET,BigData,AI]:170933152 注意这个ConcurrentLinkedQueue这个是个非阻塞队列, 这个队列是没有长度限制的, ...
- python循环队列_关于循环队列的一些讲解
前面讲到了队列的"假溢出",解决假溢出的办法就是后面满了,就再从头开始,也就是头尾相接的循环.我们把队列的这种头尾相接的顺序存储结构称为循环队列. 比如昨天的例子,rear可以改为 ...
- abcde依次进入一个队列_详解队列队形及口令(新教师必看)
队列是在一定队形下的协调而统一的行动.队形是为协同动作而采取的队伍排列形式.前者以人民解放军的"队列条令,为基础,并结合体育课的需要适当加以补充:后者是对体育课上经常采用的队列形式及其变化的 ...
- 多线程 环形缓冲区_使用环形缓冲区有效登录多线程应用程序
"有两种编写无错误程序的方法:只有第三种有效." -艾伦·J·佩利斯 在关键计算机应用程序的生命周期中,日志记录是非常重要的活动,尤其是在故障症状不明显时. 日志记录提供了故障之前 ...
- java环形数组_数组实现环形队列Java
用数组实现环形队列的特点是高效. 能快速判断队列是否 满/空: 能快速存取数据. 因为简单高效,所以甚至在硬件中都实现了环形队列. 环形队列广泛应用于网络数据的收发,和不同应用间数据交换(内核和应用程 ...
最新文章
- 看完你就知道什么是 HTTPS 了
- 夏天雷雨天机房断电了,该怎么办?,叫你几招紧急应对方法
- Android 窗口Dialog 代码以及使用
- iPhone 13将减产1000万部,因特定芯片供应不足
- php jquery api文档,使用PHP、jQuery和JSON创建公共API
- 添加用户到sudoers
- freeswitch modules 模块
- python int占几个字节_int占几个字节(c语言)?
- pythonista安卓_Android平台有哪些软件类似于iOS上的JSbox、Pythonista和Thor?
- R语言 最新TwoSampleMR、MRInstruments包安装教程
- AI智能语音识别计算器
- 迅捷校园网自动登录脚本(网页端)
- 在WordPress中嵌入YouTube视频的六种不同方式
- 修正米勒编码matlab,修正米勒编码信源解码电路及其解码方法和节能控制方法
- 免费OFD文件在线转PDF
- [USACO12FEB]牛券Cow Coupons
- 一加7t人脸识别_一加7T新机设计图发布 这款手机的外观设计如何
- matlab各个指令的含义,matlab的常用指令及其含义
- Java中import和import static的区别
- 查看已结束的中国大学MOOC课程
热门文章
- Python字符串类型及操作
- 计算机策略更新失败怎么办,大神教你解决win10系统自动更新安装失败的途径
- node.js中mysql批量插入更新的三种方法
- 关于ruby安装git(或别网站)的安装包的443port错误(用homebrew做事例)Failed to connect to raw.github.com port 443:
- c语言用递归法求杨辉三角形,关于【杨辉三角】的递归解决方法,请教。有没有大神【【高手】】...
- 学校里的流浪狗,该咋整
- “混淆梯度陷阱”:论文+代码解析(1)攻破Gradient Shattering——Thermometer Encoding
- java疯狂讲义第八章-集合
- 金蝶云星空与钉钉对接集成供应商查询打通新增表单实例
- APPIUM安装与使用