Yuri Astrakhan
Reputation: 10025
Auto-scale receiver count with crossbeam-channel in Rust
When using a multi-sender/multi-receiver channels like crossbeam-channel or async-channel, I would like to dynamically scale the number of receivers based on the channel congestion state. If there are too many pending item is the channel, more receivers should be created. If the channel is near-empty, some receivers may need to stop.
Is there an API in either of the popular multi-receiver channel implementations that would help with this? Is there a different approach for this?
Upvotes: 1
Views: 135
Answers (0)
Related Questions
- Multiple receivers on a single channel. Who gets the data?
- sending msg from sync to async-code using tokio::sync::mpsc, sender channel is always closed
- tokio::sync::broadcast::Receiver<T> is not Clone
- In Rust+Tokio, should you return a oneshot::Receiver as a processing callback?
- Closed channel vs nil channel
- Does Python have any equivalents to Rust's multi-producer single-consumer (MPSC) channels?
- Sender-side deleting pending messages in mpsc channel
- How to solve pub-sub problem in go and grpc?
- Rust lazy_static and tokio::sync::mpsc::channel in tokio::select