-
|
The best I've been able to find is broadcast - but that sends the message to all consumers and waits for all of them to receive it. What I'm after is more of a queue based system where numerous producers stuff the pipeline with tasks and numerous consumers pick the tasks off, one by one, and complete them. Does tokio have such functionality? If not, what are some other recommended crates? |
Beta Was this translation helpful? Give feedback.
Replies: 2 comments 3 replies
-
|
Tokio does not provide a traditional mpmc channel where each message is seen by exactly one receiver. If you need this, I recommend that you use the |
Beta Was this translation helpful? Give feedback.
-
|
awesome, thanks |
Beta Was this translation helpful? Give feedback.
-
Beta Was this translation helpful? Give feedback.
-
|
The broadcast channel sends the message to all receivers, which is not what the question asker wants. They want each message to go only to one receiver. |
Beta Was this translation helpful? Give feedback.
-
|
deleting the comment to save confusion, sorry! |
Beta Was this translation helpful? Give feedback.
Tokio does not provide a traditional mpmc channel where each message is seen by exactly one receiver. If you need this, I recommend that you use the
async-channelorflumecrates.