Multi-stream: a bounded queue is backpressure in one screen

A fast producer and a slow consumer need the producer to be slowed down, not a buffer that grows until the heap gives up. ArrayBlockingQueue.put blocks when it is full - that block IS the backpressure.

Full code & output

This topic is available to PRO members.