multiqueue:具有广播功能的快速mpmc队列

时间:2024-05-20 02:29:14
【文件属性】:

文件名称:multiqueue:具有广播功能的快速mpmc队列

文件大小:44KB

文件格式:ZIP

更新时间:2024-05-20 02:29:14

stream lock-free multiple-consumers broadcast-queue mpmc-queues

MultiQueue:快速MPMC广播队列 MultiQueue是一个快速绑定的mpmc队列,它支持广播/广播样式的操作 多队列基于LMAX Disruptor的队列设计,并进行了一些改进: 它可以充当期货流/接收器,因此您可以轻松设置高性能计算管道 它可以动态添加/删除生产者,每个可以有多个消费者 对于只有一个使用者和/或一个生产者的情况,它具有快速的后备功能,并且可以在运行时检测到切换 它可以在32位系统上运行,而不会影响性能或功能 在大多数情况下,无需复制即可查看直接写入队列的数据 可以将MultiQueue视为一种 ,它具有使多个独立的使用者分别接收相同数据的附加功能。 那么,为什么要在内置通道上选择MultiQueue? 一键推送到队列,MultiQueue支持向多个阅读器广播元素 在大多数情况下,MultiQueue允许在队列中就地读取元素,因此您可以广播元素而无需大量复制


【文件预览】:
multiqueue-master
----.travis.yml(198B)
----tests()
--------multicast_fut.rs(5KB)
--------mpmc_fut.rs(5KB)
----Readme.md(14KB)
----LICENSE(1KB)
----src()
--------bin()
--------maybe_acquire.rs(738B)
--------memory.rs(5KB)
--------read_cursor.rs(10KB)
--------countedindex.rs(7KB)
--------alloc.rs(292B)
--------wait.rs(9KB)
--------multiqueue.rs(35KB)
--------broadcast.rs(34KB)
--------lib.rs(10KB)
--------mpmc.rs(27KB)
--------consume.rs(794B)
--------atomicsignal.rs(1KB)
----Cargo.toml(554B)
----.gitignore(26B)

网友评论