CountDownLatch в java - это утилита синхронизации высокого уровня, которая используется для предотвращения начала обработки определенного потока до тех пор, пока все потоки не будут готовы.
Но Semaphore может делать то же самое. Итак, в чем заслуга CountDownLatch?
Еще один вопрос: если у CountDownLatch есть какие-то достоинства, Почему он был разработан для использования только один раз? Я думаю, что легко добавить метод установки для сброса счетчика.
Семантически они разные; и это важно, потому что это облегчает чтение вашего кода. Когда я вижу семафор, я сразу начинаю думать «об ограниченном объеме общего ресурса». Когда я вижу CountDownLatch, я сразу начинаю думать «куча потоков, ожидающих начала работы!» сигнал ". Если вы дадите мне первое в коде, которому действительно нужно второе, это сбивает с толку.
В этом смысле семафор, используемый в качестве CountDownLatch, чем-то похож на предложение о тропинках; будучи технически правильным, он вводит людей в заблуждение и сбивает их с толку.
С точки зрения более прагматичного использования CountDownLatch проще, если это все, что вам нужно. Проще лучше!
Что касается повторного использования CountDownLatch, это усложнит его использование. Например, предположим, что вы пытаетесь поставить в очередь потоки A, B и C для некоторой работы. Вы заставляете их ждать на защелке, а затем отпускаете ее. Затем вы сбрасываете его, предположительно, чтобы поставить в очередь потоки D, E и F для какой-то другой работы. Но что произойдет, если (из-за состояния гонки) поток B еще не был освобожден от первой защелки? Что, если он еще даже не дошел до вызова await()? Вы закрываете на нем ворота и приказываете ждать с D, E и F второго открытия? Это может даже вызвать тупик, если второе открытие зависит от работы, которую должен делать B!
У меня были те же вопросы о сбросе настроек, что и у вас, когда я впервые прочитал о CountDownLatch. Но на практике я редко даже хотел сбросить его; каждая единица «подожди, потом иди» (A-B-C, затем D-E-F) естественным образом поддается созданию собственного CountDownLatch, чтобы работать вместе с ним, и все остается простым и красивым.
Семафор с n блоками при 0.
Достигнут CountDownLatch из n блоков до 0. Затем все продолжаются примерно в одно и то же время.
Таким образом, семафор похож на привратника на дискотеке, а обратный отсчет - это как стартовый выстрел на игровом поле.
Semaphore с N разрешениями, вы можете _ 2_ N раз, и вызовы с номерами N + 1 на acquire() будут заблокированы, т. е. будут заблокированы только , когда количество разрешений достигнет нуль. --- Если вы создаете CountDownLatch со счетчиком N, любой вызов _ 5_ будет блокировать , пока счетчик не достигнет нуля, то есть N вызовов countDown(). --- Совершенно другой функционал.
- person Andreas; 02.09.2016
semaphore.acquire(0) будет по-прежнему блокироваться до тех пор, пока не будет как минимум 0 разрешений, а семафор может иметь отрицательное число разрешений, поэтому на самом деле довольно легко использовать Семафор как в основном CountUpLatch (отсчет от -numberOfCounts до 0).
- person yshavit; 02.09.2016
Семафор может делать то же самое. Итак, в чем смысл CountDownLatch?
Semaphore поддерживает набор разрешений. Каждый acquire() блокирует при необходимости до тех пор, пока не будет предоставлено разрешение, а затем забирает его. Каждый release() добавляет разрешение, потенциально освобождая блокирующего покупателя.
Однако фактические разрешительные объекты не используются; Семафор просто ведет подсчет доступного числа и действует соответственно.
Semaphore блокирует вход для входа в критический раздел, а CountDownLatch блокирует выполнение основного потока, если другие потоки не завершат свои задачи.
Взгляните на этот вопрос SE для более подробной информации:
CountDownLatch против семафора
Если у CountDownLatch есть какие-то моменты, почему он был разработан для использования только один раз?
Если вы хотите использовать его повторно, используйте CyclicBarrier
Средство синхронизации, которое позволяет набору потоков ждать друг друга, чтобы достичь общей точки барьера. CyclicBarriers полезны в программах, включающих группу потоков фиксированного размера, которые время от времени должны ждать друг друга. Барьер называется циклическим, потому что его можно повторно использовать после освобождения ожидающих потоков.
Документы Javadocs CountDownLatch цитируют следующее:
CountDownLatch - это одноразовое явление - счетчик не может быть сброшен. Если вам нужна версия, которая сбрасывает счетчик, рассмотрите возможность использования CyclicBarrier.
