CountDownLatch — одноразовое ожидание N событий: дошёл до нуля — открыт навсегда. CyclicBarrier — переиспользуемая точка встречи N потоков между раундами. Semaphore — ограничение числа одновременных доступов к ресурсу.
А ещё Phaser — гибкая замена обоим с динамическим числом участников
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
CountDownLatch(n) — счётчик вниз. countDown() уменьшает, await() ждёт нуля. Сбросить нельзя. Сценарий: главный поток ждёт, пока прогреются N сервисов или завершатся N задач.
CyclicBarrier(n, action) — каждый из n потоков вызывает await() и стоит, пока не соберутся все. Затем выполняется необязательное действие, все идут дальше, а барьер сбрасывается для следующего раунда. Сценарий: итеративные вычисления, где шаг k+1 требует результатов шага k от всех. Если участник упал или прервался, барьер «ломается» (BrokenBarrierException) у всех.
Semaphore(n) — n разрешений: acquire() берёт или ждёт, release() возвращает. Не про этапы, а про пропускную способность: не больше 10 одновременных запросов к внешнему API. Освобождать — в finally.
| CountDownLatch | CyclicBarrier | Semaphore | |
|---|---|---|---|
| назначение | дождаться N событий | встреча N потоков | ограничить параллелизм |
| переиспользование | нет | да, автоматически | да |
| кто ждёт | любые потоки | сами участники | желающие получить ресурс |
Phaser — объединяет идеи: переиспользуемый, участники регистрируются и уходят динамически.
Один верный вариант. Подумайте, потом откройте ответ.
Semaphore, CountDownLatch, CyclicBarrier, Phaser и Exchanger — что каждый делает и когда выбирать.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto