Code Farming
Sep 14, 2024 · Backend Development
How RocketMQ Handles Concurrency: Deep Dive into Its Design Principles
This article dissects RocketMQ's concurrency mechanisms, explaining why it uses ReentrantReadWriteLock with HashMaps, how Semaphore controls async send rates, the SemaphoreReleaseOnlyOnce wrapper, the CountDownLatch‑based sync‑to‑async pattern, and the CompletableFuture redesign that reduces blocking in message replication.
CompletableFutureDistributed MessagingJava
0 likes · 10 min read