الطوابير الحاجبة والمنتج والمستهلك

في هذا الدرس

build a bounded pipeline with backpressure.

الموضوعات المخطط لها

• BlockingQueue: put blocks when full, take blocks when empty; offer/poll accept timeouts.
• ArrayBlockingQueue is bounded; LinkedBlockingQueue is unbounded unless given a capacity.
• A bounded queue gives backpressure: fast producers slow down instead of exhausting memory.
• Stopping consumers: send a poison pill, or interrupt the workers.
• Choose queue size from latency tolerance, not "large to be safe".