文件名称：bus_queue-无锁有界非阻塞发布订阅队列-Rust开发
文件大小：131KB
文件格式：ZIP
更新时间：2024-06-16 13:14:48
Rust Concurrency
无锁有界无阻塞发布订阅队列（Sub-Sub Queue）这是一个发布订阅模式队列，在该队列中，发布者永远不会被慢速订阅者阻止。 无锁有界非阻塞发布订阅队列（Sub-Sub Queue）这是一个发布订阅模式队列，在该队列中，发布者永远不会被慢速订阅者阻止。 副作用是速度较慢的订户将丢失消息。 预期的用例是高吞吐量流，其中接收最新消息的优先级高于接收整个流的优先级。 市场数据馈送，实时流等。基础数据结构是弧的向量，消除了使用副本的情况。 具有无锁写/读功能-
【文件预览】：
bus-queue-master
----Cargo.toml(977B)
----.github()
--------workflows()
----src()
--------subscriber.rs(3KB)
--------swap_slot.rs(600B)
--------atomic_counter.rs(1016B)
--------async_publisher.rs(2KB)
--------ring_buffer.rs(13KB)
--------flavors()
--------lib.rs(5KB)
--------atomic()
--------async_subscriber.rs(3KB)
--------publisher.rs(1KB)
----examples()
--------async-simple.rs(715B)
--------raw-simple.rs(352B)
----modoc.config(105B)
----README.md(3KB)
----docs()
--------images()
----tests()
--------async_tests.rs(6KB)
----.gitignore(30B)
----CHANGELOG.md(4KB)