5

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();
        }
    }

}
4

2 に答える 2

6

次の修正バージョンのコードを実行してみてください。

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
完了
123
4
5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
_
_














latch.await()これは、最初のスレッドが呼び出された後、メインスレッドが実際に呼び出しのブロックを解除したことを示しています。latch.countDown()

于 2012-03-23T04:42:14.793 に答える
1

4000スレッドを開始していて、100ミリ秒しか待機していません。あなたはおそらく箱を圧倒しているでしょう（そしてすべてのスレッドはほぼ同時に終了します）。スレッドの開始ルックにスリープを追加し、タイムアウトを増やして、期待どおりに機能することを確認してください。

于 2012-03-23T03:07:06.063 に答える