手写一个LRU缓存:从原理到高并发实战

news2026/4/30 7:52:54
前言你有没有想过Redis的内存淘汰策略、MySQL的缓冲池、浏览器的后退按钮背后都用到了同一个算法LRULeast Recently Used最近最少使用。今天我们手写一个生产级的LRU缓存· O(1)时间复杂度的get和put· 支持泛型存储· 线程安全· 过期时间支持· 缓存统计---一、LRU的核心原理1. 淘汰策略当缓存满了要淘汰谁访问顺序A → B → C → D → E刚访问了E如果满了需要淘汰1个- FIFO先进先出淘汰A- LFU最不经常使用淘汰B假设B访问次数最少- LRU最近最少使用淘汰AA最久没被访问2. 数据结构选择LRU需要两个操作都是O(1)· 快速查找哈希表 O(1)· 维护访问顺序双向链表 O(1)┌─────────────────────────────────────────────────┐│ 哈希表 ││ ┌─────┐ ┌─────┐ ┌─────┐ ┌─────┐ ┌─────┐ ││ │key1 │ │key2 │ │key3 │ │key4 │ │key5 │ ││ └──┬──┘ └──┬──┘ └──┬──┘ └──┬──┘ └──┬──┘ ││ │ │ │ │ │ │└─────┼───────┼───────┼───────┼───────┼─────────┘│ │ │ │ │▼ ▼ ▼ ▼ ▼┌─────────────────────────────────────────────────┐│ 双向链表 ││ ┌─────┐ ┌─────┐ ┌─────┐ ┌─────┐ ││ │ Node │◄──►│ Node │◄──►│ Node │◄──►│ Node │ ││ │head │ │ │ │ │ │tail │ ││ └─────┘ └─────┘ └─────┘ └─────┘ ││ ↑ ↑ ││ 最久未使用 最近使用 │└─────────────────────────────────────────────────┘操作流程· get(key)哈希表找到节点 → 移动到链表头部 → 返回值· put(key, value)存在则更新并移到头不存在则创建插入头部满了则删除尾部---二、完整代码实现1. 双向链表节点定义c#include stdio.h#include stdlib.h#include string.h#include pthread.h#include time.h// 链表节点typedef struct lru_node {char *key; // 键void *value; // 值time_t expire_time; // 过期时间0表示永不过期struct lru_node *prev; // 前驱指针struct lru_node *next; // 后继指针} lru_node_t;// LRU缓存结构typedef struct {lru_node_t **hash_table; // 哈希表拉链法int hash_size; // 哈希表大小lru_node_t *head; // 链表头最近使用lru_node_t *tail; // 链表尾最久未使用int capacity; // 容量int count; // 当前数量pthread_mutex_t mutex; // 互斥锁// 统计信息long long hits; // 命中次数long long misses; // 未命中次数} lru_cache_t;2. 哈希函数c// 简单高效的哈希函数unsigned int lru_hash(const char *str, int table_size) {unsigned int hash 5381;int c;while ((c *str)) {hash ((hash 5) hash) c;}return hash % table_size;}3. 创建和销毁缓存c// 创建LRU缓存lru_cache_t *lru_cache_create(int capacity, int hash_size) {lru_cache_t *cache malloc(sizeof(lru_cache_t));if (!cache) return NULL;cache-hash_size hash_size;cache-hash_table calloc(hash_size, sizeof(lru_node_t*));if (!cache-hash_table) {free(cache);return NULL;}cache-head NULL;cache-tail NULL;cache-capacity capacity;cache-count 0;cache-hits 0;cache-misses 0;pthread_mutex_init(cache-mutex, NULL);return cache;}// 释放链表中的节点void free_node(lru_node_t *node) {if (!node) return;free(node-key);free(node-value);free(node);}// 销毁整个缓存void lru_cache_destroy(lru_cache_t *cache) {if (!cache) return;pthread_mutex_lock(cache-mutex);// 释放所有节点lru_node_t *node cache-head;while (node) {lru_node_t *next node-next;free_node(node);node next;}free(cache-hash_table);pthread_mutex_unlock(cache-mutex);pthread_mutex_destroy(cache-mutex);free(cache);}4. 链表操作c// 从链表中移除节点void remove_node(lru_cache_t *cache, lru_node_t *node) {if (node-prev) {node-prev-next node-next;} else {cache-head node-next; // 是头节点}if (node-next) {node-next-prev node-prev;} else {cache-tail node-prev; // 是尾节点}node-prev NULL;node-next NULL;}// 将节点移动到链表头部最近使用void move_to_head(lru_cache_t *cache, lru_node_t *node) {if (cache-head node) return; // 已经在头部// 先从原位置移除remove_node(cache, node);// 插入到头部node-next cache-head;node-prev NULL;if (cache-head) {cache-head-prev node;}cache-head node;if (!cache-tail) {cache-tail node;}}// 删除尾部节点最久未使用lru_node_t* pop_tail(lru_cache_t *cache) {if (!cache-tail) return NULL;lru_node_t *tail cache-tail;remove_node(cache, tail);return tail;}5. 哈希表操作c// 添加或更新哈希表项void hash_table_put(lru_cache_t *cache, const char *key, lru_node_t *node) {unsigned int index lru_hash(key, cache-hash_size);// 检查是否已存在相同key的节点更新时使用lru_node_t **curr cache-hash_table[index];while (*curr) {if (strcmp((*curr)-key, key) 0) {// 替换旧节点*curr node;return;}curr ((*curr)-next);}// 插入新节点头插法node-next cache-hash_table[index];cache-hash_table[index] node;}// 从哈希表中获取节点lru_node_t* hash_table_get(lru_cache_t *cache, const char *key) {unsigned int index lru_hash(key, cache-hash_size);lru_node_t *node cache-hash_table[index];while (node) {if (strcmp(node-key, key) 0) {return node;}node node-next;}return NULL;}// 从哈希表中删除节点void hash_table_remove(lru_cache_t *cache, const char *key) {unsigned int index lru_hash(key, cache-hash_size);lru_node_t **curr cache-hash_table[index];while (*curr) {if (strcmp((*curr)-key, key) 0) {lru_node_t *to_remove *curr;*curr to_remove-next;return;}curr ((*curr)-next);}}6. 核心方法put和getc// 设置键值对int lru_cache_put(lru_cache_t *cache, const char *key, void *value, int ttl_seconds) {if (!cache || !key) return -1;pthread_mutex_lock(cache-mutex);// 检查是否已存在lru_node_t *node hash_table_get(cache, key);if (node) {// 更新现有节点free(node-value);node-value value;node-expire_time ttl_seconds 0 ? time(NULL) ttl_seconds : 0;// 移到头部move_to_head(cache, node);pthread_mutex_unlock(cache-mutex);return 0;}// 创建新节点node malloc(sizeof(lru_node_t));if (!node) {pthread_mutex_unlock(cache-mutex);return -1;}node-key strdup(key);node-value value;node-expire_time ttl_seconds 0 ? time(NULL) ttl_seconds : 0;node-prev NULL;node-next NULL;// 检查容量if (cache-count cache-capacity) {// 淘汰最久未使用的节点lru_node_t *tail pop_tail(cache);if (tail) {hash_table_remove(cache, tail-key);free_node(tail);cache-count--;}}// 插入新节点到头部node-next cache-head;if (cache-head) {cache-head-prev node;}cache-head node;if (!cache-tail) {cache-tail node;}// 添加到哈希表hash_table_put(cache, key, node);cache-count;pthread_mutex_unlock(cache-mutex);return 0;}// 获取键对应的值void* lru_cache_get(lru_cache_t *cache, const char *key) {if (!cache || !key) return NULL;pthread_mutex_lock(cache-mutex);lru_node_t *node hash_table_get(cache, key);if (!node) {cache-misses;pthread_mutex_unlock(cache-mutex);return NULL;}// 检查是否过期if (node-expire_time 0 time(NULL) node-expire_time) {// 过期了删除节点remove_node(cache, node);hash_table_remove(cache, key);free_node(node);cache-count--;cache-misses;pthread_mutex_unlock(cache-mutex);return NULL;}// 移动到头部move_to_head(cache, node);cache-hits;pthread_mutex_unlock(cache-mutex);return node-value;}7. 统计和调试接口c// 获取命中率float lru_cache_hit_rate(lru_cache_t *cache) {long long total cache-hits cache-misses;if (total 0) return 0;return (float)cache-hits / total;}// 获取命中次数long long lru_cache_hits(lru_cache_t *cache) {return cache-hits;}// 获取未命中次数long long lru_cache_misses(lru_cache_t *cache) {return cache-misses;}// 获取当前缓存大小int lru_cache_size(lru_cache_t *cache) {return cache-count;}// 清空缓存void lru_cache_clear(lru_cache_t *cache) {pthread_mutex_lock(cache-mutex);lru_node_t *node cache-head;while (node) {lru_node_t *next node-next;free_node(node);node next;}memset(cache-hash_table, 0, cache-hash_size * sizeof(lru_node_t*));cache-head NULL;cache-tail NULL;cache-count 0;pthread_mutex_unlock(cache-mutex);}// 打印缓存内容调试用void lru_cache_print(lru_cache_t *cache) {pthread_mutex_lock(cache-mutex);printf(LRU Cache (head → tail): );lru_node_t *node cache-head;while (node) {printf(%s , node-key);node node-next;}printf(\n);pthread_mutex_unlock(cache-mutex);}---三、测试代码基础功能测试cint main() {// 创建容量为3的LRU缓存lru_cache_t *cache lru_cache_create(3, 16);printf( LRU缓存基础测试 \n\n);// 插入数据int *v1 malloc(sizeof(int)); *v1 100;int *v2 malloc(sizeof(int)); *v2 200;int *v3 malloc(sizeof(int)); *v3 300;int *v4 malloc(sizeof(int)); *v4 400;lru_cache_put(cache, A, v1, 0);lru_cache_put(cache, B, v2, 0);lru_cache_put(cache, C, v3, 0);lru_cache_print(cache); // 期望: A B C 或 C B A取决于实现细节// 访问BB应该移到头部printf(访问B\n);int *val lru_cache_get(cache, B);printf(获取B: %d\n, val ? *val : -1);lru_cache_print(cache);// 插入D容量3应该淘汰最久未使用的Aprintf(插入D\n);lru_cache_put(cache, D, v4, 0);lru_cache_print(cache);// 尝试获取A应该不存在val lru_cache_get(cache, A);printf(获取A: %s\n, val ? 存在 : 不存在已被淘汰);// 统计printf(\n 统计信息 \n);printf(命中次数: %lld\n, lru_cache_hits(cache));printf(未命中次数: %lld\n, lru_cache_misses(cache));printf(命中率: %.2f%%\n, lru_cache_hit_rate(cache) * 100);printf(当前大小: %d\n, lru_cache_size(cache));lru_cache_destroy(cache);return 0;}运行结果 LRU缓存基础测试 LRU Cache (head → tail): C B A访问B获取B: 200LRU Cache (head → tail): B C A插入DLRU Cache (head → tail): D B C获取A: 不存在已被淘汰 统计信息 命中次数: 1未命中次数: 1命中率: 50.00%当前大小: 3过期时间测试cvoid test_expiration() {lru_cache_t *cache lru_cache_create(10, 32);printf(\n 过期时间测试 \n);int *v malloc(sizeof(int)); *v 123;lru_cache_put(cache, temp, v, 2); // 2秒后过期printf(立即获取: %d\n, *(int*)lru_cache_get(cache, temp));printf(等待3秒...\n);sleep(3);void *result lru_cache_get(cache, temp);printf(3秒后获取: %s\n, result ? 存在 : 已过期);lru_cache_destroy(cache);}并发测试c#include pthread.h#include unistd.hlru_cache_t *global_cache;int stop 0;int test_counter 0;void *worker_read(void *arg) {int id *(int*)arg;char key[16];for (int i 0; i 10000 !stop; i) {snprintf(key, sizeof(key), key_%d, rand() % 20);void *val lru_cache_get(global_cache, key);// 模拟工作usleep(1);}return NULL;}void *worker_write(void *arg) {int id *(int*)arg;char key[16];for (int i 0; i 2000 !stop; i) {snprintf(key, sizeof(key), key_%d, rand() % 20);int *val malloc(sizeof(int));*val id * 1000 i;lru_cache_put(global_cache, key, val, 0);usleep(10);}return NULL;}void test_concurrent() {global_cache lru_cache_create(100, 128);pthread_t readers[10], writers[5];int ids[15];printf(\n 并发测试 \n);printf(启动10个读线程5个写线程...\n);for (int i 0; i 10; i) {ids[i] i;pthread_create(readers[i], NULL, worker_read, ids[i]);}for (int i 0; i 5; i) {ids[10 i] i;pthread_create(writers[i], NULL, worker_write, ids[10 i]);}sleep(5);stop 1;for (int i 0; i 10; i) {pthread_join(readers[i], NULL);}for (int i 0; i 5; i) {pthread_join(writers[i], NULL);}printf(最终缓存大小: %d\n, lru_cache_size(global_cache));printf(命中率: %.2f%%\n, lru_cache_hit_rate(global_cache) * 100);lru_cache_destroy(global_cache);}---四、性能优化技巧1. 减少锁竞争c// 方案分段锁typedef struct {lru_cache_t *segments[16];pthread_mutex_t segment_locks[16];} segmented_lru_t;unsigned int get_segment_index(const char *key) {return lru_hash(key, 16);}void *segmented_get(segmented_lru_t *cache, const char *key) {int idx get_segment_index(key);pthread_mutex_lock(cache-segment_locks[idx]);void *val lru_cache_get(cache-segments[idx], key);pthread_mutex_unlock(cache-segment_locks[idx]);return val;}2. 使用内存池c// 预分配节点减少malloc开销typedef struct {lru_node_t *free_list;pthread_mutex_t pool_lock;} node_pool_t;lru_node_t *node_pool_alloc(node_pool_t *pool) {pthread_mutex_lock(pool-pool_lock);if (pool-free_list) {lru_node_t *node pool-free_list;pool-free_list node-next;pthread_mutex_unlock(pool-pool_lock);return node;}pthread_mutex_unlock(pool-pool_lock);return malloc(sizeof(lru_node_t));}3. 提升缓存友好性c// 将key和value连续存储typedef struct {char key[64]; // 固定长度避免指针跳转char value[256];time_t expire_time;struct lru_node *prev;struct lru_node *next;} compact_node_t;---五、LRU的应用场景场景 说明 典型产品数据库缓冲池 缓存热点数据页 MySQL InnoDB Buffer PoolRedis淘汰策略 内存不足时淘汰key Redis maxmemory-policy浏览器缓存 后退/前进按钮 Chrome Back/Forward CacheCDN缓存 边缘节点缓存热门内容 CloudFront, Akamai操作系统页缓存 缓存磁盘数据页 Linux Page Cache---六、与其他淘汰算法对比算法 原理 优点 缺点LRU 淘汰最久未使用 实现简单局部性好 扫描一次会污染LFU 淘汰使用次数最少 抗扫描 需要维护频率ARC 自适应LRULFU 效果好 实现复杂FIFO 淘汰最早进入 极简单 效果差---七、总结通过这篇文章你学会了· LRU缓存的核心原理哈希表 双向链表· 完整的生产级实现支持过期、统计、并发· 性能优化技巧分段锁、内存池· 实际应用场景这个LRU缓存可以直接用于你的项目。把它改成更通用的模板版本加上更多配置选项就是一个完整的缓存组件。下一篇预告《从LRU到LFU手写一个自适应缓存淘汰算法》---评论区分享一下你用LRU解决过什么问题

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2554731.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

SpringBoot-17-MyBatis动态SQL标签之常用标签

文章目录 1 代码1.1 实体User.java1.2 接口UserMapper.java1.3 映射UserMapper.xml1.3.1 标签if1.3.2 标签if和where1.3.3 标签choose和when和otherwise1.4 UserController.java2 常用动态SQL标签2.1 标签set2.1.1 UserMapper.java2.1.2 UserMapper.xml2.1.3 UserController.ja…

wordpress后台更新后 前端没变化的解决方法

使用siteground主机的wordpress网站,会出现更新了网站内容和修改了php模板文件、js文件、css文件、图片文件后,网站没有变化的情况。 不熟悉siteground主机的新手,遇到这个问题,就很抓狂,明明是哪都没操作错误&#x…

网络编程(Modbus进阶)

思维导图 Modbus RTU(先学一点理论) 概念 Modbus RTU 是工业自动化领域 最广泛应用的串行通信协议,由 Modicon 公司(现施耐德电气)于 1979 年推出。它以 高效率、强健性、易实现的特点成为工业控制系统的通信标准。 包…

UE5 学习系列(二)用户操作界面及介绍

这篇博客是 UE5 学习系列博客的第二篇,在第一篇的基础上展开这篇内容。博客参考的 B 站视频资料和第一篇的链接如下: 【Note】:如果你已经完成安装等操作,可以只执行第一篇博客中 2. 新建一个空白游戏项目 章节操作,重…

IDEA运行Tomcat出现乱码问题解决汇总

最近正值期末周,有很多同学在写期末Java web作业时,运行tomcat出现乱码问题,经过多次解决与研究,我做了如下整理: 原因: IDEA本身编码与tomcat的编码与Windows编码不同导致,Windows 系统控制台…

利用最小二乘法找圆心和半径

#include <iostream> #include <vector> #include <cmath> #include <Eigen/Dense> // 需安装Eigen库用于矩阵运算 // 定义点结构 struct Point { double x, y; Point(double x_, double y_) : x(x_), y(y_) {} }; // 最小二乘法求圆心和半径 …

使用docker在3台服务器上搭建基于redis 6.x的一主两从三台均是哨兵模式

一、环境及版本说明 如果服务器已经安装了docker,则忽略此步骤,如果没有安装,则可以按照一下方式安装: 1. 在线安装(有互联网环境): 请看我这篇文章 传送阵>> 点我查看 2. 离线安装(内网环境):请看我这篇文章 传送阵>> 点我查看 说明&#xff1a;假设每台服务器已…

XML Group端口详解

在XML数据映射过程中&#xff0c;经常需要对数据进行分组聚合操作。例如&#xff0c;当处理包含多个物料明细的XML文件时&#xff0c;可能需要将相同物料号的明细归为一组&#xff0c;或对相同物料号的数量进行求和计算。传统实现方式通常需要编写脚本代码&#xff0c;增加了开…

LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器的上位机配置操作说明

LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器专为工业环境精心打造&#xff0c;完美适配AGV和无人叉车。同时&#xff0c;集成以太网与语音合成技术&#xff0c;为各类高级系统&#xff08;如MES、调度系统、库位管理、立库等&#xff09;提供高效便捷的语音交互体验。 L…

(LeetCode 每日一题) 3442. 奇偶频次间的最大差值 I (哈希、字符串)

题目&#xff1a;3442. 奇偶频次间的最大差值 I 思路 &#xff1a;哈希&#xff0c;时间复杂度0(n)。 用哈希表来记录每个字符串中字符的分布情况&#xff0c;哈希表这里用数组即可实现。 C版本&#xff1a; class Solution { public:int maxDifference(string s) {int a[26]…

【大模型RAG】拍照搜题技术架构速览:三层管道、两级检索、兜底大模型

摘要 拍照搜题系统采用“三层管道&#xff08;多模态 OCR → 语义检索 → 答案渲染&#xff09;、两级检索&#xff08;倒排 BM25 向量 HNSW&#xff09;并以大语言模型兜底”的整体框架&#xff1a; 多模态 OCR 层 将题目图片经过超分、去噪、倾斜校正后&#xff0c;分别用…

【Axure高保真原型】引导弹窗

今天和大家中分享引导弹窗的原型模板&#xff0c;载入页面后&#xff0c;会显示引导弹窗&#xff0c;适用于引导用户使用页面&#xff0c;点击完成后&#xff0c;会显示下一个引导弹窗&#xff0c;直至最后一个引导弹窗完成后进入首页。具体效果可以点击下方视频观看或打开下方…

接口测试中缓存处理策略

在接口测试中&#xff0c;缓存处理策略是一个关键环节&#xff0c;直接影响测试结果的准确性和可靠性。合理的缓存处理策略能够确保测试环境的一致性&#xff0c;避免因缓存数据导致的测试偏差。以下是接口测试中常见的缓存处理策略及其详细说明&#xff1a; 一、缓存处理的核…

龙虎榜——20250610

上证指数放量收阴线&#xff0c;个股多数下跌&#xff0c;盘中受消息影响大幅波动。 深证指数放量收阴线形成顶分型&#xff0c;指数短线有调整的需求&#xff0c;大概需要一两天。 2025年6月10日龙虎榜行业方向分析 1. 金融科技 代表标的&#xff1a;御银股份、雄帝科技 驱动…

观成科技:隐蔽隧道工具Ligolo-ng加密流量分析

1.工具介绍 Ligolo-ng是一款由go编写的高效隧道工具&#xff0c;该工具基于TUN接口实现其功能&#xff0c;利用反向TCP/TLS连接建立一条隐蔽的通信信道&#xff0c;支持使用Let’s Encrypt自动生成证书。Ligolo-ng的通信隐蔽性体现在其支持多种连接方式&#xff0c;适应复杂网…

铭豹扩展坞 USB转网口 突然无法识别解决方法

当 USB 转网口扩展坞在一台笔记本上无法识别,但在其他电脑上正常工作时,问题通常出在笔记本自身或其与扩展坞的兼容性上。以下是系统化的定位思路和排查步骤,帮助你快速找到故障原因: 背景: 一个M-pard(铭豹)扩展坞的网卡突然无法识别了,扩展出来的三个USB接口正常。…

未来机器人的大脑:如何用神经网络模拟器实现更智能的决策?

编辑&#xff1a;陈萍萍的公主一点人工一点智能 未来机器人的大脑&#xff1a;如何用神经网络模拟器实现更智能的决策&#xff1f;RWM通过双自回归机制有效解决了复合误差、部分可观测性和随机动力学等关键挑战&#xff0c;在不依赖领域特定归纳偏见的条件下实现了卓越的预测准…

Linux应用开发之网络套接字编程(实例篇)

服务端与客户端单连接 服务端代码 #include <sys/socket.h> #include <sys/types.h> #include <netinet/in.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <arpa/inet.h> #include <pthread.h> …

华为云AI开发平台ModelArts

华为云ModelArts&#xff1a;重塑AI开发流程的“智能引擎”与“创新加速器”&#xff01; 在人工智能浪潮席卷全球的2025年&#xff0c;企业拥抱AI的意愿空前高涨&#xff0c;但技术门槛高、流程复杂、资源投入巨大的现实&#xff0c;却让许多创新构想止步于实验室。数据科学家…

深度学习在微纳光子学中的应用

深度学习在微纳光子学中的主要应用方向 深度学习与微纳光子学的结合主要集中在以下几个方向&#xff1a; 逆向设计 通过神经网络快速预测微纳结构的光学响应&#xff0c;替代传统耗时的数值模拟方法。例如设计超表面、光子晶体等结构。 特征提取与优化 从复杂的光学数据中自…