mediumSystem Design

What is backpressure and how do you handle it?

104 views
01

Understand the problem

Explain backpressure.

backpressure
02

Attempt it yourself

Sketch your approach before reading the solution — that's what interviews test.

Stuck? AI Nudge Available

Get a conceptual hint to guide your logic without spoiling the final implementation.

03

Study the solution

The solution is waiting

Give it an honest attempt first — then compare your thinking with the full walkthrough.

04

Read the code

Bounded queue applies backpressure
Run Playground
import queue, threading, time

q = queue.Queue(maxsize=3)         # bounded -> put() blocks when full

def consumer():
    while True:
        job = q.get()
        if job is None:
            break
        print("  processing", job)
        time.sleep(0.04)           # slow worker
        q.task_done()

threading.Thread(target=consumer, daemon=True).start()

for i in range(1, 7):
    q.put(i)                       # BLOCKS when full -> natural backpressure
    print("enqueued", i)
q.join()
print("done")
05

Join the discussion

Discussion (0)

Sign in to join the discussion.

No responses yet. Be the first to share what you think.