MemTable 落盘必须异步,因同步刷盘会阻塞写入;需用后台线程+队列管理 flush,配合 shared_ptr 防段错误、限流防 OOM,并确保 SSTable 有序输出、O_DIRECT 写入、fsync 后 rename 实现 crash-safe。

MemTable 落盘为什么必须异步
同步刷盘会阻塞写入,一旦 MemTable 满(比如 64MB),主线程调用 Flush() 写磁盘,可能卡住几十毫秒——尤其在机械盘或高负载 SSD 上。LSM-Tree 的写放大和延迟敏感性决定了:落盘动作必须移交后台线程,让前台只做内存追加。
用 std::thread + std::queue 实现基础异步刷盘
别碰 std::async 或协程——它们生命周期难控,容易在线程销毁时触发未完成的 Flush() 崩溃。稳妥做法是手管一个后台线程 + 无锁队列(或带锁队列):
-
MemTable满后,不直接刷盘,而是把指针(std::shared_ptr)塞进std::queue,再用std::mutex保护; - 后台线程循环
pop队列,调用WriteSSTableFile()把键值对序列化为 SSTable 格式(如按 key 排序、建 block、加 index/bloom filter); - 刷完后,把生成的
.sst文件名加入VersionSet,并原子更新当前current_version; - 注意:
MemTable必须用shared_ptr,否则后台线程还在读,前台已释放就段错误。
避免 flush 线程堆积导致 OOM
如果写入太快,后台 flush 跟不上,std::queue 里积压大量 MemTable,内存爆掉。必须限流:
- 设置最大待刷
MemTable数(比如 3 个),超限时前台写入阻塞在std::condition_variable::wait(); - 不要用信号量或简单计数器——得和 flush 完成事件联动,每次 flush 成功后 notify;
- 更激进的做法:当积压达阈值,触发 minor compaction 合并多个小
MemTable再刷,减少文件数量(但增加 CPU 和 I/O); - 监控项必须有:
flush_queue_size、memtable_flush_duration_us,否则问题发生时根本不知道卡在哪。
文件写入阶段的关键细节
从 MemTable 到 SSTable 不只是 dump,顺序和完整性决定后续读取是否可靠:
-
MemTable内部是跳表或红黑树,遍历时必须按 key 升序输出,否则 SSTable 的二分查找失效; - 写文件要用
O_DIRECT(Linux)或FILE_FLAG_NO_BUFFERING(Windows)绕过 page cache,防止 flush 后 cache 还没落盘就被 crash 丢数据; - 写完先
fsync()数据文件,再rename()临时文件为正式.sst名——这是原子发布的关键; - 别忘了写
MANIFEST文件记录新 SSTable 的 level、file number、最小/最大 key,否则重启后整个层级元信息丢失。
真正麻烦的不是“怎么写”,而是“怎么确保 crash-safe”——哪怕只差一次 fsync 或一次 rename 顺序错,重启后就可能读到脏数据或找不到文件。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











