文件名称:data-priority-queue
文件大小:13KB
文件格式:ZIP
更新时间:2024-06-23 09:55:24
C++
data-priority-queue 服务端、可恢复的消息优先级队列 应用场景 流水线式的消息/数据处理系统(A -> B -> C)往往需要处理大量的消息,但消息类型间又有优先级的高低之分。 为确保高优先级的消息类型优先通过该系统,各模块都需要确保对高优先级消息的优先处理。 data-priority-queue用于各模块内部,接收、排序到来的消息,并吐出高优先级的消息供模块处理。 配合消息队列使用更好,消息队列往往只对消息进行分类或者分通道,无法区别高低优先级,data-pq是对消息队列的补充。 实现原理 排序 data-pq内部有多个子队列组成,不同的子队列有优先级高低之分,同一个子队列内消息有先后之分。 对应的消息进入各自相应优先级的子队列,取消息时按优先级高低依次遍历,返回data-pq中当前最高优先级的消息。 可恢复 data-pq的子队列每收到一个消息都以二进制格式持久化到
【文件预览】:
data-priority-queue-master
----test()
--------test()
--------test_main.cpp(2KB)
--------common.h(516B)
--------Makefile(741B)
----src()
--------fifo_queue.h(2KB)
--------data_backup.h(2KB)
--------fifo_queue.cpp(3KB)
--------pri_queue.h(2KB)
--------Makefile(860B)
--------pri_queue.cpp(5KB)
--------data_backup.cpp(5KB)
----.gitignore(16B)
----Makefile(88B)
----README.md(2KB)