当前位置：首页 > news >正文

【中间件】brpc_基础_TimerThread

news 来源：原创 2025/8/23 17:03:44

文章目录

TimerThread
- 1 简介
- 2 主要设计点
- - 2.1 数据结构：分层时间轮（Hierarchical Timing Wheel）
  - 2.2 线程模型
  - 2.3 任务管理
- 3 关键代码分析
- - 3.1 类定义（`timer_thread.h`）
  - 3.2 时间轮初始化（`timer_thread.cpp`）
  - 3.3 任务调度（`timer_thread.cpp`）
  - 3.4 线程主循环（`timer_thread.cpp`）
- 4 性能优化
- 5 关键参数与配置
- 6 应用场景
- 7 总结

TimerThread

1 简介

BRPC 中用于 高效管理定时任务 的组件，负责调度延时任务（如 RPC 超时处理、周期性任务）。

设计目标：支持高并发、低延迟的定时任务管理，

适用场景：大规模分布式系统中的超时控制和任务调度。

2 主要设计点

2.1 数据结构：分层时间轮（Hierarchical Timing Wheel）

时间轮层级：BRPC 使用 多层时间轮（例如秒级、毫秒级），每层时间轮覆盖不同的时间精度和范围，减少任务迁移频率。
时间槽（Bucket）：每个时间轮分为多个槽位，任务按到期时间分布到对应槽位中。
任务迁移：高层时间轮的任务在到期后迁移到低层时间轮，逐步细化调度精度。

2.2 线程模型

独立线程：TimerThread 运行在单独的线程中，通过 bthread 异步唤醒 或 usleep 轮询 检查任务到期。
低延迟唤醒：使用 butex 或 epoll 实现高效休眠唤醒机制，减少 CPU 空转。

2.3 任务管理

任务结构：

struct TimerTask {int64_t expiration_ms;  // 到期时间（绝对时间戳）void (*fn)(void*);      // 回调函数void* arg;              // 回调参数TimerTask* next;        // 链表指针
};

任务插入：根据到期时间计算所属时间轮层级和槽位，插入对应链表。
任务执行：到期槽位的任务链表被批量取出并执行回调。

3 关键代码分析

3.1 类定义（`timer_thread.h`）

class TimerThread {
public:TimerThread();~TimerThread();// 启动定时器线程int start(const TimerThreadOptions* options);// 提交定时任务（绝对时间 expiration_ms）void schedule(void (*fn)(void*), void* arg, int64_t expiration_ms);// 停止线程void stop();private:// 时间轮层级定义struct Wheel {int64_t tick_ms;       // 本层时间轮每个槽位的时间跨度int num_slots;         // 槽位数量TimerTask** buckets;   // 槽位任务链表int64_t current_tick;  // 当前指向的槽位};std::vector<Wheel> _wheels;// 线程控制bthread_t _tid;std::atomic<bool> _stop;// 任务队列同步butil::Mutex _mutex;butil::ConditionVariable _cond;
};

3.2 时间轮初始化（`timer_thread.cpp`）

int TimerThread::start(const TimerThreadOptions* options) {// 初始化多层时间轮（例如：毫秒级、秒级）_wheels.emplace_back(Wheel{1, 64});    // 1ms per tick, 64 slots (64ms range)_wheels.emplace_back(Wheel{64, 64});   // 64ms per tick, 64 slots (~4s range)_wheels.emplace_back(Wheel{4096, 64}); // 4096ms per tick, 64 slots (~4min range)// 启动线程return bthread_start_background(&_tid, nullptr, TimerThread::run, this);
}

3.3 任务调度（`timer_thread.cpp`）

void TimerThread::schedule(void (*fn)(void*), void* arg, int64_t expiration_ms) {TimerTask* task = new TimerTask{expiration_ms, fn, arg, nullptr};butil::MutexLockGuard lock(_mutex);// 计算任务所属的时间轮层级和槽位int level = find_wheel_level(expiration_ms);int slot = calculate_slot(expiration_ms, level);// 插入对应槽位链表task->next = _wheels[level].buckets[slot];_wheels[level].buckets[slot] = task;
}

3.4 线程主循环（`timer_thread.cpp`）

void* TimerThread::run(void* arg) {TimerThread* t = static_cast<TimerThread*>(arg);while (!t->_stop.load(std::memory_order_relaxed)) {int64_t now_ms = butil::gettimeofday_ms();// 处理所有到期任务for (auto& wheel : t->_wheels) {int64_t current_tick = now_ms / wheel.tick_ms;int slot = current_tick % wheel.num_slots;TimerTask* head = wheel.buckets[slot];while (head != nullptr) {TimerTask* next = head->next;if (head->expiration_ms <= now_ms) {head->fn(head->arg);  // 执行回调delete head;} else {// 重新插入更精确的时间轮t->reschedule(head);}head = next;}wheel.buckets[slot] = nullptr;}// 休眠至下一个检查点usleep(next_check_interval_ms * 1000);}return nullptr;
}

4 性能优化

分层时间轮：减少任务迁移次数，提升插入和删除效率。
批量处理：每次处理一个槽位的所有任务，减少锁竞争。
惰性删除：任务未到期时重新插入更合适的时间轮，避免重复计算。
无锁任务队列：使用 bthread 的原子操作减少同步开销。

5 关键参数与配置

时间轮层级：通过 TimerThreadOptions 可配置层级数量和每层参数。
检查间隔：动态计算下一个最近任务的到期时间，优化休眠时长。
线程优先级：通过 bthread_attr_t 设置定时器线程的调度优先级。

6 应用场景

RPC 超时控制：为每个 RPC 请求设置超时任务，超时后取消请求。
心跳检测：周期性发送心跳包，维护连接活性。
缓存刷新：定时刷新本地缓存，保证数据一致性。

7 总结

TimerThread 通过分层时间轮和高效线程调度机制，实现了高吞吐、低延迟的定时任务管理。其核心优势包括：

高效任务插入：平均时间复杂度 O(1)。
低调度开销：通过分层减少任务迁移。
线程安全：结合 bthread 的原子操作和锁机制。

改进方向：

支持高精度定时：如微秒级定时（需调整时间轮层级）。
任务取消接口：允许动态取消已提交的任务。
资源限制：防止恶意任务耗尽内存。

【中间件】brpc_基础_TimerThread

文章目录 TimerThread1 简介2 主要设计点2.1 数据结构：分层时间轮（Hierarchical Timing Wheel）2.2 线程模型2.3 任务管理 3 关键代码分析3.1 类定义（timer_thread.h）3.2 时间轮初始化（timer_thread.cpp&…...

编程日记 2025/8/23 17:03:44

拷贝多个Excel单元格区域为图片并粘贴到Word

Excel工作表Sheet1中有两个报表，相应单元格区域分别定义名称为Report1和Report2，如下图所示。现在需要将图片拷贝图片粘贴到新建的Word文档中。示例代码如下。 Sub Demo()Dim oWordApp As ObjectDim ws As Worksheet: Set ws ThisWorkbook.Sheets(&…...

编程日记 2025/8/21 1:02:29

网络原理（6）—— 应用层之HTTP协议

目录一. 应用层二. 重要应用层协议DNS(Domain Name System) 三. HTTP协议 3.1 HTTP抓包工具 3.2 HTTP格式 3.2.1 请求 3.2.2 响应 3.3 HTTP的工作过程一. 应用层应用层协议就像是人们之间的交流规则，它帮助不同的计算机程序（应用&#xff09…...

编程日记 2025/8/23 17:02:07

Linux55yum源配置、本机yum源备份，本机yum源配置，网络Yum源配置，自建yum源仓库

参考太晚了计划先休息了大概保存...

编程日记 2025/8/20 4:43:42

250505_HTML

HTML 1. HTML5语法与基础标签1.1 HTML5特性1.1.1 空白折叠现象1.1.2 转义字符 1.2 HTML注释1.3 基础标签1.3.1 div标签1.3.2 标题标签1.3.3 段落标签1.3.1.3.1.3.1.3. 1. HTML5语法与基础标签 1.1 HTML5特性 1.1.1 空白折叠现象 1.1.2 转义字符 1.2 HTML注释 1.3 基础标签 1…...

编程日记 2025/8/21 1:02:23

1. 设计哲学：让字面量“活”起来，提升表达力和安全性

C11引入的用户定义字面量（User-Defined Literals，简称UDL）是语言层面为程序员打开的一扇“自定义表达式”的大门。它允许我们为字面量（比如数字、字符、字符串）添加自定义后缀，从而让代码更具语义化、更易读…...

编程日记 2025/8/21 1:02:20

【KWDB 创作者计划】基于 ESP32 + KWDB 的智能环境监测系统实战

一开始萌生这个想法，其实是源自我办公桌上的那颗“小胖子”——一块 ESP32 开发板。它陪我度过了不少调试夜，也让我对物联网有了真正的感知。恰逢 KaiwuDB 举办征文活动，我便想着，何不将我日常积攒下来的一些硬件和数据库实战经验…...

编程日记 2025/8/20 21:03:32

AVHRR中国积雪物候数据集（1980-2020年）

数据集摘要本数据集基于1980-2020年5kmAVHRR逐日无云积雪面积产品，制备了中国长时间序列积雪物候数据集。数据集按照不同的物候参数共分为积雪日数、积雪初日、积雪终日3个目录，每个目录下包含40个子文件，为逐水文年积雪物候参数&#xff0c…...

编程日记 2025/8/20 23:34:02

PCB设计中电感封装的选型

在PCB设计中，电感封装的选型直接影响电路性能、布局效率、热管理能力及系统可靠性。合理的封装选择不仅能优化空间利用率，还能提升电磁兼容性（EMC）和长期稳定性。以下从封装类型、尺寸参数、应用场景适配、布局协同设计、热管理策…...

编程日记 2025/8/21 1:02:14

LintCode第766题,LintCode第1141题,LintCode第478题

第766题描述判断给出的年份 n 是否为闰年. 如果 n 为闰年则返回 true 闰年是包含额外一天的日历年. 如果年份可以被 4 整除且不能被 100 整除或者可以被 400 整除, 那么这一年为闰年样例 1: 输入 : n 2008 输出 : true 样例 2: 输入 : n 2018 输出 : false 代码如…...

编程日记 2025/8/21 1:02:12

三十一、基于HMM的词性标注

基于HMM的中文词性标注 1 实验目标理解HMM模型的原理和基本问题理解HMM的实现命名实体识别的具体步骤掌握HMM模型实现命名实体识别的方法 2 实验环境 HMM的中文词性标注的实验环境。 3 实验步骤该项目主要由3个代码文件组成，分别为hmm.py、tagging.py和run.p…...

编程日记 2025/8/23 6:48:52

MCUboot 中的 BOOT_SWAP_TYPE_PERM 功能介绍

目录概述 1 Image 数据结构 1.1 Image介绍 1.2 Swap info 2 BOOT_SWAP_TYPE_PERM 功能 2.1 功能定义 2.2 典型工作流程 3 BOOT_SWAP_TYPE_xx的其他功能 3.1 BOOT_SWAP_TYPE_REVERT 3.2 三中模式的比较 4 使用机制 4.1 实现细节 4.2 使用场景 4.3 开发者注意事…...

编程日记 2025/8/21 1:02:08

数学复习笔记 2

前言朋友和我讨论了一个二重积分题，非常有意思。内容非常细致。整理如下： 二重积分题目来源是 1000 上面的 16 题，积分区域是一个偏心圆，偏心圆的圆心在 y 轴上面，偏心圆是关于 y 轴对称的，可以看关于…...

编程日记 2025/8/20 9:07:03

从入门到登峰-嵌入式Tracker定位算法全景之旅 Part 5 ｜地图匹配与轻量 SLAM：HMM/Viterbi 与简化图优化

Part 5 ｜地图匹配与轻量 SLAM：HMM/Viterbi 与简化图优化在本章中，我们将在 ESP32-S3 这样的资源受限平台上，实现地图匹配（Map Matching）和轻量级图优化（Lightweight SLAM）功能。通过隐马尔可夫模型（HMM）+ Viterbi 算法，以及简化的图优化思路，校正定位轨迹，提升…...

编程日记 2025/8/21 1:02:03

Amazon Bedrock Converse API：开启对话式AI新体验

Amazon Bedrock Converse API：开启对话式AI新体验前言在当今人工智能飞速发展的时代，对话式AI已成为众多应用的核心组成部分。从智能客服到智能助手，对话式AI为用户带来了便捷且高效的交互体验。而Amazon Bedrock Converse API的出现&…...

编程日记 2025/8/21 1:02:01

软考系统架构设计师系列知识点之杂项集萃（54）

接前一篇文章：软考系统架构设计师系列知识点之杂项集萃（53） 第87题某银行系统采用Factory Method方法描述其不同账户之间的关系，设计出的类图如下所示。其中与Factory Method的“Creator”角色对应的类是（&#xff…...

编程日记 2025/8/23 8:28:05

第三章 - 软件质量工程体系

1 概述系统工程学的思想系统工程学是为了研究多个子系统构成的整体系统所具有的多种不同目标的相互协调，以期系统功能的最优化、最大限度地发挥系统组成部分的能力而发展起来的一门科学。软件质量工程体系的建立建立和实施质量管理体系的方法确定顾客和其…...

编程日记 2025/8/20 22:23:36

#基础Machine Learning 算法（上）

机器学习算法的分类机器学习算法大致可以分为三类： 监督学习算法 (Supervised Algorithms）:在监督学习训练过程中，可以由训练数据集学到或建立一个模式（函数 / learning model），并依此模式推测新的实例。…...

编程日记 2025/8/21 1:01:53

【YOLO11改进】改进Conv、颈部网络STFEN、以及引入PIOU用于小目标检测！

改进后的整体网络架构改进一：RFD模块（Conv） YOLOv11模型的跨步卷积下采样虽然快速聚合了局部特征，并且实现了较高的计算效率，但其固有的信息压缩机制会导致细粒度特征的不可逆丢失。针对特征保留与计算效率的平衡问题，本文采用RFD模块替换跨步卷积下采样模块。RFD模块通…...

编程日记 2025/8/20 17:21:19

算法之上的权力——空域治理的政治哲学

当AI算法成为空域资源分配的核心机制，我们不得不直面一个核心问题：谁拥有算法，谁控制算法，谁审查算法？调度系统表面上是中立技术，实则承载了深刻的价值判断与权力结构。本章提出“算法即治理”命题&#xf…...

编程日记 2025/8/21 1:01:49

虚幻引擎作者采访

1万小时编程_哔哩哔哩_bilibili https://www.youtube.com/watch?v477qF6QNSvc 提姆斯温尼是一位传奇性的视频游戏程序员，Epic Games 的创始人兼首席执行官。该公司开发了虚幻引擎、堡垒之夜、战争机器、虚幻竞技场等许多开创性和有影响力的视频游戏。他哥哥…...

编程日记 2025/8/21 2:34:45

一、下载CodeBlocks 25.03版本 1.去Sourceforge.net Code::Blocks - Browse /Binaries/25.03/Windows at SourceForge.net 下载codeblocks-25.03mingw-nosetup.zip 2.解压到d盘，并把目录改为codeblocks 二、.下载wxWidgets 3.2.8 1. 去Sourceforge.net wxWidg…...

编程日记 2025/8/21 1:01:26

Python 整理3种查看神经网络结构的方法

1. 网络结构代码 import torch import torch.nn as nn# 定义Actor-Critic模型 class ActorCritic(nn.Module):def __init__(self, state_dim, action_dim):super(ActorCritic, self).__init__()self.actor nn.Sequential(# 全连接层，输入维度为 state_dim&#xf…...

编程日记 2025/8/21 1:01:24

【Bootstrap V4系列】学习入门教程之组件-卡片（Card）

Bootstrap V4系列学习入门教程之组件-卡片（Card） 卡片（Card）一、Example二、Content types 内容类型2.1 Body 主体2.2 Titles, text, and links 标题、文本和链接2.3 Images 图片2.4 List groups 列表组2.5 Kitchen sink 洗涤槽…...

编程日记 2025/8/23 2:30:13

AI Agent开发第50课-机器学习的基础-线性回归如何应用在商业场景中

开篇虽然我们这个系列主讲AI Agent，但是这个系列是一个喂饭式从0到深入的全AI类计算机教程系列，它主要面向的是培养出一个个AI时代的程序员，不是像外部那种很水的只是做做套壳、聊天、绘图小工具的急功近利式教学。而机器学习是现代AI的基础与基石，一些机器学习、深度学习…...

编程日记 2025/8/21 2:29:54

代码随想录第34天：动态规划7（打家劫舍问题：链式、环式、树式房屋）

一、背包问题小结 1.递推公式： 1.问能否能装满背包（或者最多装多少）：dp[j] max(dp[j], dp[j - nums[i]] nums[i]) 2.问装满背包有几种方法：dp[j] dp[j - nums[i]] 3.问背包装满最大价值：dp[j] max…...

编程日记 2025/8/20 23:52:43

网络安全自动化：找准边界才能筑牢安全防线

数字时代，企业每天要面对成千上万的网络攻击。面对庞大的服务器群、分散的团队和长期不重启的设备，很多企业开始思考：哪些安全操作适合交给机器自动处理？哪些必须由人工把关？今天我们就用大白话聊聊这件事。一、这些事…...

编程日记 2025/8/22 7:41:57

ctfshow——web入门361~368

最近练习ssti 当 Web 应用程序使用模板引擎动态生成 HTML 页面或其他类型的输出时，如果用户输入未经过充分验证或转义就被直接嵌入到模板中，就可能发生 SSTI 攻击。攻击者可以利用这个弱点注入恶意模板代码，该代码将在服务器端执行。常见的…...

编程日记 2025/8/22 21:13:17

备忘录模式（Memento Pattern）

🧠 备忘录模式（Memento Pattern） 备忘录模式是行为型设计模式之一。它通过将对象的状态存储在一个备忘录中，允许对象在不暴露其内部结构的情况下，保存和恢复自己的状态。该模式允许将对象的状态保存到备忘录中&#…...

编程日记 2025/8/20 4:09:11

五一假期作业

sub_process.c #include <stdio.h> // 标准输入输出库 #include <pthread.h> // POSIX线程库 #include <sys/ipc.h> // IPC基础定义（如消息队列/共享内存） #include <sys/msg.h> // 消息队列操作相关…...

编程日记 2025/8/21 1:01:13

Multi Agents Collaboration OS：专属多智能体构建—基于业务场景流程构建专属多智能体

背景随着人工智能技术的飞速发展，大型语言模型（LLM）的能力不断突破，单一智能体的能力边界逐渐显现。为了应对日益复杂的现实世界任务，由多个具备不同能力、可以相互协作的智能体组成的多智能体系统 (Multi-Agent Sys…...

编程日记 2025/8/20 20:32:58

数据库的二级索引

二级索引 10.1 二级索引作为额外的键表结构正如第8章提到的，二级索引本质上是包含主键的额外键值对。每个索引通过B树中的键前缀来区分。 type TableDef struct {// 用户定义的部分Name stringTypes []uint32 // 列类型Cols []string // 列名Indexes …...

编程日记 2025/8/21 1:01:11

湖北理元理律师事务所：债务法律服务的民生价值重构

当前我国居民杠杆率达62.3%（央行2023年数据），债务问题已从经济议题演变为社会议题。湖北理元理律师事务所通过构建覆盖咨询、备案、规划的全链条服务，试图在法律框架内探索债务危机的社会化解决方案。民生导向的服务设计 1.阶梯…...

编程日记 2025/8/20 9:08:48

DotNetBrowser 3.2.0 版本发布啦！

包含来自 Chromium 135 的安全修复支持自定义用户代理客户端提示（User Agent Client Hints）在 Avalonia 离屏渲染模式中支持拖放（Drag & Drop）功能 🔗 点击此处了解更多详情。 🆓 免费试用 30 天。...

编程日记 2025/8/20 8:42:28

PyTorch 张量与自动微分操作

笔记 1 张量索引操作 import torch # 下标从左到右从0开始(0->第一个值), 从右到左从-1开始 # data[行下标, 列下标] # data[0轴下标, 1轴下标, 2轴下标] def dm01():# 创建张量torch.manual_seed(0)data torch.randint(low0, high10, size(4, 5))print(data->,…...

编程日记 2025/8/21 1:01:05

C语言数据在内存中的存储详解

在 C 语言的编程世界里，理解数据在内存中的存储方式是非常重要的，它能帮助我们更好地掌握数据类型、内存管理和程序性能优化等内容。今天，我就来给大家详细讲解数据在内存中的存储，包括整数、大小端字节序和浮点数的存储方式&…...

编程日记 2025/8/22 11:48:01

【AI大模型】SpringBoot整合Spring AI 核心组件使用详解

目录一、前言二、Spring AI介绍 2.1 Spring AI介绍 2.2 Spring AI主要特点 2.3 Spring AI核心组件 2.4 Spring AI应用场景 2.5 Spring AI优势 2.5.1 与 Spring 生态无缝集成 2.5.2 模块化设计 2.5.3 简化 AI 集成 2.5.4 支持云原生和分布式计算 2.5.5 安全性保障…...

编程日记 2025/8/21 1:01:00

linux-文件操作

在 Linux 系统中，文件操作与管理是日常使用和系统管理的重要组成部分。下面将详细介绍文件的复制、移动、链接创建，以及文件查找、文本处理、排序、权限管理等相关知识。一、文件的复制在 Linux 里，cp 命令可用于复制文件或目录&#xff…...

编程日记 2025/8/21 12:26:10

丢失的数字 --- 位运算

目录一：题目二：算法原理三：代码实现一：题目题目链接： 268. 丢失的数字 - 力扣（LeetCode） 二：算法原理三：代码实现 class Solution { public:int missingNumb…...

编程日记 2025/8/19 8:53:48

从Rtos到Linux：学习的策略

这里目的只是为了学习，哪天工作需要用上了能更顺利的上手，写文章的目的是为了记录和便于查询。工作的前两年主要是以mcu裸机为主，目的是压缩资源以最少的ram和flash实现最多的功能，后来五年做的东西越来越复杂的跑的rtos&#xff…...

编程日记 2025/8/22 3:05:56

BUUCTF——Mark loves cat

BUUCTF——Mark loves cat 进入靶场简单的看了一下功能点扫一下目录吧扫目录发现一个.git 下一下源码看看找到个flag.php和index.php <?php$flag file_get_contents(/flag);再看看index.php（代码有点长，所以只留了后面有用的） &…...

编程日记 2025/8/20 12:24:41