每日一博 - 使用环形队列实现高效的延时消息

偏执的太偏执、 2022-09-02 05:24 122阅读 0赞

### 文章目录 ###

*  Pre
 *  方案A
 *  方案B
 *  总结

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70]

--------------------

# Pre #

来个场景： 24小时后将未进行某个Action的业务，执行另外一个动作。 比如 24小时未付款的订单，取消。

你可能会说

![在这里插入图片描述][89395785d754489f98843d72bb050093.png]

--------------------

# 方案A #

来个定时呗 ，每隔半小时 ，扫描数据库订单表，将完成时间超过24小时的订单，取消掉。

![在这里插入图片描述][cce5a163221a4561b317ea0d19b32144.png]

But…

这方案有些明显的缺点啊，老哥

*  （1）轮询效率比较低
 *  （2）时效性不好，假设每小时轮询一次，最坏的情况下，时间误差会达到1小时；

--------------------

那如何既保证效率的同时，又保证实时性呢？

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70 1]

--------------------

# 方案B #

来说下核心思路

高效延时消息，包含两个重要的数据结构：

*  环形队列。例如可以创建一个大小为3600的环形队列
 *  任务集合。环上每一个格是一个Set

同时，启动一个timer：

*  每隔1s，timer在环形队列中移动一格
 *  用一个Current Index来标识当前所在的格；

Task结构中包含两个重要属性：

*  Cycle-Num：用于标记当第几圈扫描到这个格时，执行任务
 *  Task-Function：到时间后需要执行的任务函数

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70 2]

假设当前Current Index指向第一格，当有延时消息到达之后，例如希望3620秒之后，触发一个延时消息任务：

*  （1）计算这个Task应该放在哪一个格，现在是在第1格，3610秒之后，应该是第11格，所以这个Task应该加入第11格的`Set<Task>`中；
 *  （2）计算这个Task的Cycle-Num，由于环形队列是3600格（每秒移动一格，正好1小时），这个任务是3610秒后执行。所以应该绕3610/3600=1圈之后再执行，于是Cycle-Num=1；

Current Index每秒移动一格，当移动到下一格时，遍历这个格的**Set**，看看每个Task的Cycle-Num是不是0：

*  如果不是0，说明任务时间还没到，还需要多移动几圈，将Cycle-Num减1；
 *  如果是0，说明到这个Task的执行时间了，取出Task-Funciton丢给工作线程执行，并把这个Task从`Set<Task>`中删除

Warning : 不要直接用timer线程来执行任务

--------------------

# 总结 #

总体思路就是这个样子，总结下有点

*  （1）效率高，无需再轮询订单表；一个订单，任务只执行一次
 *  （2）实时性好，精确到秒  
    ![在这里插入图片描述][4961c9d2f4c54baea499126464e5a695.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70]: /images/20220829/edb5deefba5d4d169bedf305cb3cd433.png
[89395785d754489f98843d72bb050093.png]: /images/20220829/741e838e905643bbac172c2f7c7ab0cb.png
[cce5a163221a4561b317ea0d19b32144.png]: /images/20220829/fa87266a0c034a65a0a39f78d3871952.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70 1]: /images/20220829/7b4029e198ab432cbbbae7944aecd317.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70 2]: /images/20220829/c9af2acea1ed4a279c128d885a722442.png
[4961c9d2f4c54baea499126464e5a695.png]: /images/20220829/de665179f8f04e64a2da623f5ca35536.png