Skip to content

A SPMC (Single Producer Multi Consumer) broadcasting channel to broadcast notifications between threads

License

Notifications You must be signed in to change notification settings

DarthBenro008/thread-broadcaster

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

thread-broadcaster

release GitHub License Documentation

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

use core::time;
use std::thread;

use thread_broadcaster::{BroadcastListener, Broadcaster};

fn main() {
    let (b, s) = Broadcaster::<String>::new();
    let s2 = s.clone();
    thread::spawn(move || {
        let ls1 = BroadcastListener::register_broadcast_listener(s);
        for msg in ls1.channel {
            println!(
                "got broadcast with data: {} on thread {:#?}",
                msg,
                thread::current().id()
            );
        }
    });
    thread::spawn(move || {
        let ls2 = BroadcastListener::register_broadcast_listener(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::from_secs(1));
        b.broadcast("something to broadcast".to_string());
        // 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

About

A SPMC (Single Producer Multi Consumer) broadcasting channel to broadcast notifications between threads

Topics

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages