博客
关于我
定时器的实现
阅读量:730 次
发布时间:2019-03-21

本文共 2188 字,大约阅读时间需要 7 分钟。

定时器设计概述

1. 定时器概述

定时器是服务端应用程序中负责执行时间相关任务的核心组件。服务端逻辑主要由两个事件驱动:网络事件和时间事件。不同框架对这两种事件的处理方式有所不同。

在单线程模型中(如 Nginx、Redis 等),网络事件和时间事件通过同一线程同步处理;而在多线程模型中(如 Skynet 等),则分别由不同的线程处理网络事件和时间事件。

1.1 单线程定时器实现

while (!quit) {    int now = get_now_time(); // 单位:ms    int timeout = get_nearest_timer() - now;    if (timeout < 0) timeout = 0;    int nevent = epoll_wait(epfd, ev, nev, timeout); // 利用 epoll_wait 实现定时器    for (int i = 0; i < nevent; i++) {        // 处理网络事件    }}

1.2 多线程定时器实现

void* thread_timer(void* thread_param) {    init_timer();    while (!quit) {        update_timer(); // 更新定时器检测        sleep(t); // sleep 时间 t    }    clear_timer();    return NULL;}pthread_create(&pid, NULL, thread_timer, &thread_param);

2. 定时器设计

2.1 接轴设计

// 初始化定时器void init_timer();// 添加定时器cbNode* add_timer(int expire, callback cb);// 删除定时器bool del_timer(Node* node);// 找到最近要触发的定时任务Node* find_nearest_timer();// 更新定时器检测void update_timer();

2.2 数据结构选择

时间轮需要高效的数据结构支持,主要有以下四种选择:

2.2.1 红黑树

红黑树可以支持 O(logN) 增、删、查操作。 дополнитель有序树结构允许快速查找最小节点,但需要维护节点的有序性。

2.2.2 最小堆

最小堆以完全二叉树形式存在,支持 O(logN) 增、查操作,删除操作通过辅助数据结构加速。堆的最小节点总是根节点。

2.2.3 跳表

跳表的增、删、查操作复杂度为 O(logN),但其空间复杂度较高。虽然最小节点查找时间复杂度为 O(1),但大数据量下不具备高效性。

2.2.4 时间轮

时间轮可以在 O(1) 时间复杂度下完成增、删、查操作,最小节点查找也为 O(1)。适合多个定时任务同时触发的情况。

2.3 红黑树实现定时器

void ngx_rbtree_insert_timer_value(ngx_rbtree_node_t *temp, ngx_rbtree_node_t *node, ngx_rbtree_node_t *sentinel) {    ngx_rbtree_node_t **p;    for ( ;; ) {        p = ((ngx_rbtree_key_int_t)(node->key - temp->key) < 0) ? &temp->left : &temp->right;        if (*p == sentinel) {            break;        }        temp = *p;    }    *p = node;    node->parent = temp;    node->left = sentinel;    node->right = sentinel;    ngx_rbt_red(node);}

2.4 最小堆实现定时器

最小堆的增操作需要满足完全二叉树定义,加入新节点后可能需要上浮操作。删除操作需要借由上升或下沉来维护堆的结构。

2.5 时间轮实现定时器

int seconds[60]; // 表盘刻度描述int tick = 0;// 时间轮每秒移动一次while (!quit) {    tick = (tick + 1) % 60; // 秒针循环}

3. 时间轮应用实例

3.1 单层级时间轮

用于解决心跳检测中常见的时延问题。例如,客户端每5秒发送心跳包,服务端若10秒内未收到心跳包则清除连接。

单层级时间轮设计

  • 准备一个固定大小的数组存储连接数据。
  • 每秒检查一次心跳包发送情况。
  • 使用指针移动数组位置,实现心跳检测。
  • 多层级时间轮设计

    通过将定时任务按优先级分层,实现多级时间轮共享机制。例如,紧急任务放在第一层,普通任务放在第二层等。

    3.2 时间轮优化建议

  • 合理设置数组长度,考虑连接数量和心跳检测时间。
  • 优化指针移动方式,避免重复计算。
  • 维护使用计数器,确保心跳检测逻辑正确。
  • 通过以上设计,可以编写高效、灵活的定时器系统,满足不同场景的服务端需求。

    转载地址:http://xjngz.baihongyu.com/

    你可能感兴趣的文章
    opencv videocapture读取视频cap.isOpened 输出总是false
    查看>>
    opencv waitKey() 函数理解及应用
    查看>>
    OpenCV 中的图像转换
    查看>>
    OpenCV 人脸识别 C++实例代码
    查看>>
    OpenCV 在 Linux 上的 python 与 anaconda 无法正常工作.收到未实现 cv2.imshow() 的错误
    查看>>
    Opencv 完美配置攻略 2014 (Win8.1 + Opencv 2.4.8 + VS 2013)上
    查看>>
    opencv 模板匹配, 已解决模板过大程序不工作的bug
    查看>>
    OpenCV 错误:(-215)size.width>0 &&函数imshow中的size.height>0
    查看>>
    opencv&Python——多种边缘检测
    查看>>
    opencv&python——高通滤波器和低通滤波器
    查看>>
    OpenCV+Python识别车牌和字符分割的实现
    查看>>
    OpenCV-Python接口、cv和cv2的性能比较
    查看>>
    OpenCV/Python/dlib眨眼检测
    查看>>
    opencv1-加载、修改、保存图像
    查看>>
    opencv10-形态学操作
    查看>>
    opencv11-提取水平直线和垂直直线
    查看>>
    opencv12-图像金字塔
    查看>>
    opencv13-基本阈值操作
    查看>>
    opencv14-自定义线性滤波
    查看>>
    opencv15-边缘处理
    查看>>