thread-broadcaster
Thread Broadcaster is a Single Channel Multi-Producer (SPMC) library that enables the sending of notifications between threads. Unlike most Multi-Producer Multi-Consumer (MPMC) implementations, Thread Broadcaster ensures that all listeners receive the data, rather than just the first one.
🤔 Features
- Single Channel Multi-Producer (SPMC) architecture
- Tad bit faster than MPMC (thanks to crossbeam-channel!)
- Senders and Receivers can be cloned and shared among threads.
- Simple and intuitive API for sending and receiving notifications
- Asynchronous notification broadcasting between threads
- Support
tracing for debugs
⚡️ Quickstart
```rust
use core::time;
use std::thread;
use thread_broadcaster::{BroadcastListener, Broadcaster};
fn main() {
let (b, s) = Broadcaster::::new();
let s2 = s.clone();
thread::spawn(move || {
let ls1 = BroadcastListener::registerbroadcastlistener(s);
for msg in ls1.channel {
println!(
"got broadcast with data: {} on thread {:#?}",
msg,
thread::current().id()
);
}
});
thread::spawn(move || {
let ls2 = BroadcastListener::registerbroadcastlistener(s2);
for msg in ls2.channel {
println!(
"got broadcast with data: {} on thread {:#?}",
msg,
thread::current().id()
);
}
});
thread::spawn(move || {
// we wait for registration
thread::sleep(time::Duration::fromsecs(1));
b.broadcast("something to broadcast".tostring());
// we wait for listeners to pickup before being dropped
thread::sleep(time::Duration::from_secs(2));
})
.join()
.unwrap();
}
```
⬇️ Installation
cargo add thread-broadcaster
🤝 Contributions
- Feel Free to Open a PR/Issue for any feature or bug(s).
- Make sure you follow the community guidelines.
- Feel free to open an issue to ask a question/discuss anything about melonpan.
- Have a feature request? Open an Issue!
⚖ License
Copyright 2022 Hemanth Krishna
Licensed under MIT License : https://opensource.org/licenses/MIT
Made with ❤ and multiple cups of coffee