Hard Resilience Patterns

Bulkhead with FlatMap Concurrency

Traducción al español en progresoEl contenido detallado de esta lección aún se está traduciendo. Mientras tanto, se muestra en inglés.

Simulate the bulkhead pattern using flatMap concurrency. Create a Flux of task IDs 1 through 6 and process them with flatMap limited to 2 concurrent tasks. Each task should print "Processing task <id>" and return "Done <id>". Print results.

flatMap(mapper, concurrency) limits how many inner publishers run simultaneously.

Esperado

Processing task 1
Done 1
Processing task 2
Done 2
Processing task 3
Done 3
Processing task 4
Done 4
Processing task 5
Done 5
Processing task 6
Done 6

Anterior Siguiente

Main.kt

Bulkhead with FlatMap Concurrency

hard⏱ 15 minkotlinreactorchallengeresilience

flatMap(mapper, concurrency) limits how many inner publishers run simultaneously.

Why this works

The bulkhead pattern limits concurrency to prevent resource exhaustion. flatMap(mapper, concurrency) controls how many inner publishers subscribe concurrently. With concurrency=2, only 2 tasks are processed at a time.

Expected output

Processing task 1
Done 1
Processing task 2
Done 2
Processing task 3
Done 3
Processing task 4
Done 4
Processing task 5
Done 5
Processing task 6
Done 6

Bulkhead with FlatMap Concurrency

Traducción al español en progresoEl contenido detallado de esta lección aún se está traduciendo. Mientras tanto, se muestra en inglés.

flatMap(mapper, concurrency) limits how many inner publishers run simultaneously.

Esperado

Processing task 1 Done 1 Processing task 2 Done 2 Processing task 3 Done 3 Processing task 4 Done 4 Processing task 5 Done 5 Processing task 6 Done 6

Bulkhead with FlatMap Concurrency

hard⏱ 15 minkotlinreactorchallengeresilience

flatMap(mapper, concurrency) limits how many inner publishers run simultaneously.

Why this works

Expected output

Processing task 1 Done 1 Processing task 2 Done 2 Processing task 3 Done 3 Processing task 4 Done 4 Processing task 5 Done 5 Processing task 6 Done 6