Why not design an mpmc?

help
1

I know std::sync::mpsc; is used to create a multi production and single consumption channel,In that case, why is there no design of more production and more consumption, or single production and more consumption, If there is a similar one, I think I don't need to use rabbitmq, kafaka pulsar and so on. I can use Rust to do MQ :slight_smile: lol~

use std::sync::mpsc;
use std::thread;

fn main(){
    let (tx, yx) = mpsc::channel()
    
    thread::spawn(move || {
      tx.send(String::from("rust :)")).unwrap();
    });
}
2

mpsc mpmc spmc

3

Crossbeam has an mpmc.

4 Likes
4

Take a look at the crossbeam_channel crate; it’s the de facto standard for more advanced channels than std provides.

3 Likes
5

Thanks. I'm watching it

6

This topic was automatically closed 90 days after the last reply. We invite you to open a new topic if you have further questions or comments.