Prompt Title: CountDownLatch

CountDownLatch (счетчик ожидания) - это многопоточный механизм синхронизации в Java, который позволяет одному или нескольким потокам ждать, пока другие потоки завершат выполнение определенных операций, прежде чем продолжить свою работу. Он представлен классом java.util.concurrent.CountDownLatch.

CountDownLatch работает следующим образом:

1. Создается объект CountDownLatch с указанным начальным счетчиком. Этот счетчик обычно устанавливается равным количеству задач, которые должны завершиться, прежде чем ожидающий поток будет разблокирован.

2. В каждом потоке, который должен дождаться завершения определенных задач, вызывается метод await() на объекте CountDownLatch. Если счетчик не достиг нуля, поток блокируется и ждет, пока счетчик не станет равным нулю.

3. Когда каждая из задач завершает свою работу, она вызывает метод countDown() на объекте CountDownLatch. Этот метод уменьшает счетчик на единицу.

4. Когда счетчик достигает нуля, все ожидающие потоки разблокируются и продолжают выполнение.

CountDownLatch полезен в ситуациях, когда нужно дождаться завершения нескольких параллельных задач, прежде чем продолжить выполнение какой-то общей операции. Это может быть полезно, например, для ожидания завершения запуска нескольких потоков или задач перед тем, как начать обработку результатов их работы.

Пример использования CountDownLatch:

javaCopy code
import java.util.concurrent.CountDownLatch;

public class Example {
    public static void main(String[] args) throws InterruptedException {
        int numberOfTasks = 3;
        CountDownLatch latch = new CountDownLatch(numberOfTasks);

        for (int i = 0; i < numberOfTasks; i++) {
            new Thread(new Task(latch)).start();
        }

        // Ждем, пока все задачи завершатся
        latch.await();

        // Все задачи завершились, продолжаем выполнение
        System.out.println("All tasks have completed.");
    }

    static class Task implements Runnable {
        private final CountDownLatch latch;

        Task(CountDownLatch latch) {
            this.latch = latch;
        }

        @Override
        public void run() {
            // Выполняем какую-то работу
            // ...

            // Сообщаем о завершении задачи
            latch.countDown();
        }
    }
}

В этом примере три потока выполняют задачи, и основной поток ждет, пока все задачи не завершатся, с помощью CountDownLatch.