CountDownLatch - понимание await и countDown - PullRequest
Новая
       2

CountDownLatch - понимание await и countDown

2 голосов
/ 23 марта 2012

Согласно Javadoc: CountDownLatch инициализируется с заданным количеством. Методы await блокируются, пока текущий счетчик не достигнет нуля.

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

Но основной поток ожидает завершения всех потоков. Кроме того, я не присоединился к основному потоку до конца других потоков. Почему основной поток ожидает? 

    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.atomic.AtomicLong;

public class Sample implements Runnable {

    private CountDownLatch latch;

    public Sample(CountDownLatch latch)
    {
        this.latch = latch;
    }
    private static AtomicLong number = new AtomicLong(0);

    public long next() {
         return number.getAndIncrement();
    }

    public static void main(String[] args) {

        CountDownLatch latch = new CountDownLatch(1);
        for (int threadNo = 0; threadNo < 4000; threadNo++) {
          Runnable t = new Sample(latch);
          new Thread(t).start();
        }
        try {
            latch.countDown();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        try {
            latch.await();
            Thread.sleep(100);
            System.out.println("Count:"+next());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

Ответы [ 2 ]

5 голосов
/ 23 марта 2012

Попробуйте запустить следующую модифицированную версию вашего кода: 

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicLong;

public class Test implements Runnable {

    private CountDownLatch latch;

    public Test(CountDownLatch latch)
    {
        this.latch = latch;
    }
    private static AtomicLong number = new AtomicLong(0);

    public long next() {
         return number.getAndIncrement();
    }

    public static void main(String[] args) {

        CountDownLatch latch = new CountDownLatch(1);
        for (int threadNo = 0; threadNo < 1000; threadNo++) {
          Runnable t = new Test(latch);
          new Thread(t).start();
        }
        try {
            latch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println( "done" );
    }

    @Override
    public void run() {
        try {
            Thread.sleep(1000 + (int) ( Math.random() * 3000 ));
            System.out.println(next());
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            latch.countDown();
        }
    }

}

Вы должны увидеть что-то вроде:

0
done
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

Это указывает на то, что основной поток фактически разблокировал вызов latch.await() после вызовапервый поток называется latch.countDown()

1 голос
/ 23 марта 2012

вы запускаете 4000 потоков, и они ждут только 100 миллисекунд. Скорее всего, вы переполняете окно (и все потоки будут заканчиваться примерно в одно и то же время). добавьте сон в ваш поток, начните смотреть и попробуйте увеличить время ожидания, чтобы увидеть, как оно работает, как вы ожидаете.

...