multiqueue
multiqueue copied to clipboard
schets
A fast mpmc queue with broadcast capabilities
I'm trying to make a data bus with this lib and have a problem. When thread begins reading from stream, it uses 100% cpu. Here is the example: ``` let...
Hello :crab: , I recently submitted a bug report to the [`multiqueue2`](https://crates.io/crates/multiqueue2/0.1.7) crate which is maintained from a fork of this crate. The bug was fixed a few days ago...
I'm using multiqueue::broadcast_queue in a situation where I spawn a new thread for each websocket client and call add_stream() for each before spawning the thread, so it gets moved into...
An example test which will fail (or more accurately: block infinitely) ```rust #[test] fn futures_do_not_block() { let (tx, rx) = multiqueue::broadcast_fut_queue::(16); let mut rt = tokio::runtime::Runtime::new().unwrap(); rt.block_on( rx .for_each(|_| {...
The following code deadlocks on my machine. You might have to run several times to hit the bug. ```rust extern crate crossbeam; extern crate multiqueue; fn main() { const MESSAGES:...
In latency benchmarks for scenarios with many-producers, and 4-12 consumers, I found the broadcast queue to have much worse performance at the tail end than separate mpmc queues that producers...
I wonder if `MPMCSender` is unwind-safe? If yes, then can it be marked as such?
Hi! It'd be really helpful if there were examples of using the futures-based APIs. I'm currently trying out multiqueue in a Gotham-based webapp and when I try to use the...
Maybe the `parked` fields should also be renamed to `tasks` for clarity?
