Tag
4 posts
Backpressure is how a slow consumer tells a fast producer to slow down. Without it, queues grow until memory runs out. Rust's bounded channels and semaphores make it explicit.
Split work across a bounded pool of workers and merge the results: a producer, bounded channels for backpressure, N workers, a collector and clean shutdown. A Tokio pipeline with ordering, errors and cancellation handled.
std::sync::mpsc moves values between threads through a channel. Learn send, recv, iterating, multiple producers and what a closed channel means.
Tokio has four channel types: mpsc, oneshot, broadcast and watch. Pick by how many senders and receivers you have and whether late messages matter.