CountDownLatch является частью пакета java.util.concurrent и представляет собой механизм синхронизации, который позволяет одному или нескольким потокам ждать, пока определенное количество других потоков завершат выполнение своих задачи. Это особенно полезно в ситуациях, когда один поток зависит от выполнения нескольких других потоков.
При создании экземпляра CountDownLatch необходимо установить начальное значение для счетчика операций. Этот счетчик уменьшается на единицу каждый раз, когда поток завершает работу. В то же время другой поток, ожидающий завершения операций, блокируется до тех пор, пока счетчик не станет равным нулю.
После уменьшения счетчика до нуля, CountDownLatch не может быть сброшен или использован повторно. Если вам нужно многократно синхронизировать выполнение потоков, вам может потребоваться создать новый экземпляр CountDownLatch.
CountDownLatch является потокобезопасным и может использоваться несколькими потоками одновременно без дополнительной синхронизации.
Пример использования
В этом примере после создании счетчика, мы запускаем пять потоков. Каждый поток ждет одну секунду для имитации работы, а затем вызовом latch.countDown() уменьшает значение счетчика на единицу.
Основной поток вызывает latch.await() и блокируется до тех пор, пока счетчик не будет сброшен до нуля.
Давайте посмотрим на консольный вывод этого примера:
Как видно, потоки завершают свою работу в случайном порядке, т.к. они выполняются параллельно. Порядок может меняться при каждом запуске программы. Однако вывод "Вся работа завершена!" всегда будет последним, т.к. он происходит в основном потоке, заблокированном до тех пор, пока счетчик не будет равен нулю.
Заключение
CountDownLatch является важным инструментом для управления и синхронизации потоков в многопоточных приложениях Java. Правильное его применение может упростить разработку и обеспечить эффективное использование ресурсов. Однако необходимо помнить об его ограничениях и использовать его с умом в зависимости от требований вашего приложения.