CountDownLatch и Semaphore
В общем то,достаточно сжатая информация об удобных вещах в пакете java.util.concurrent,
а точнее о паре вещей оттуда.
CountDownLatch
CountDownLatch класс защелка,позволяет задержать поток(и) до тех пор,пока не выполнится определенное условие,а именно пока счетчик заданный в конструкторе не дойдет до 0.
Вообще создание объекта происходит следующим образом
CountDownLatch latch = new CountDownLatch(3);//по количеству потоков которых мы будем ждать
И 2 основных метода
countDown и await.
Метод await заставляет текущий поток ожидать,пока счетчик защелки не станет равен 0.
Метод countDown декрементит счетчик заданный в конструкторе и как только он дойдет до 0,потоки продолжат выполнение.
Вот пример со скачками(пример не мой,я только напихал больше комментариев по коду,ну и сократил лишнее)
class Race
{
private Random rand = new Random();
private int distance = 50;
private List horses = Arrays.asList("Vanek","Robert","Polson","Rak");
public void run() throws InterruptedException
{
System.out.println("And the horses are stepping up to the gate...");
final CountDownLatch start = new CountDownLatch(1);//защелка для одновременного старта для всех коней,1-тк защелка для основного потока выполнения
start.await();
final CountDownLatch finish = new CountDownLatch(horses.size());//защелка для финиша, а здесь по количеству лошадей
final List places = Collections.synchronizedList(new ArrayList<>());
horses.forEach(horse -> new Thread(() -> {
try {
System.out.println(horse + " stepping up to the gate...");
start.await(); // Блокируем поток,чтобы не было не одного фальстарта у наших коней
int traveled = 0;//пройденный путь для коня
while (traveled < distance) {
// каждые 0-2 секунды лошадь проходит дистанцию 0-14 пунктов
Thread.sleep(rand.nextInt(3) * 1000);
traveled += rand.nextInt(15);
System.out.println(horse + " advanced to " + traveled + "!");
}
finish.countDown();//уменьшение счетчика защелки,тк мы будем ждать именно этого момента в самой программе и когда последний конь финиширует исполнение завершится
System.out.println(horse + " crossed the finish!");
places.add(horse);
} catch (InterruptedException intEx) {
System.out.println("ABORTING RACE!!!");
intEx.printStackTrace();
}
}).start());
System.out.println("And... they're off!");
start.countDown();//снимаем нашу защелку для старта
finish.await();//ожидаем финиша наших скакунов
System.out.println("And we have our winners!");
System.out.println(places.get(0) + " took the gold...");
System.out.println(places.get(1) + " got the silver...");
System.out.println("and " + places.get(2) + " took home the bronze.");
}
public static void main(String[] args) throws InterruptedException {
new Race().run();
}
}
Вот как то так.
Теперь про класс Semaphore.
Он, как видно из названия,служит для ограничения количества потоков использующих определенный ресурс.
Создается объект как то так
Semaphore available = new Semaphore(3);//по количеству потоков которые будут активны
И 2 основных метода acquire() и release().
acquire()-Уменьшает счетчик доступных потоков(который мы задали в конструкторе) на 1.
release()-Соответственно освобождает его и увеличивает счетчик.
Небольшой пример
public static void main(String[] args)
{
Runnable limitedCall = new Runnable() {
final Random rand = new Random();
final Semaphore available = new Semaphore(3);
int count = 0;
public void run()
{
int time = rand.nextInt(15);
int num = count++;
try
{
available.acquire();//задействуем поток
System.out.println("Executing " +
"long-running action for " +time +
" seconds... #" + num);
Thread.sleep(time * 1000);
System.out.println("Done with #" + num + "!");
available.release();//после его работы освобождаем
}
catch (InterruptedException intEx)
{
intEx.printStackTrace();
}
}
};
for (int i=0; i<10 data-blogger-escaped-i="" data-blogger-escaped-limitedcall="" data-blogger-escaped-new="" data-blogger-escaped-pre="" data-blogger-escaped-start="" data-blogger-escaped-thread="">
Создаем 10 потоков(можно убедиться выполнив команду jstack),однако только 3 из них активны.Как только один их потоков освобождает семафор,другой занимает его место.
Вот и все.
