2

私はJavaでcountdownLatchを使用する方法を学んでおり、コードで以下に示すように簡単な例を作成しました。

そのメカニズムについて私が学んだことは、1つのスレッドだけが他のスレッドが作業を完了するまで待機するように強制する方法であり、待機していたスレッドは、他のスレッドが終了するとジョブを開始します.

私の質問は、4 つのスレッド 't1、t2、t3、および t4' があり、それらが記載されている順序で開始され、先頭/前のスレッドが終了したときに各スレッドが開始する必要がある場合です。つまり、t2 は t1 を待って t1 が終了したときに開始し、t3 は t2 を待って t2 が終了したときに開始し、t4 は t3 を待って t3 が終了したときに開始します。

1-CountDownLatch と循環バリアを使用してこれを行う方法は?

2- CountDownLatch クラスのコンストラクタに渡される countDown パラメータは、待機しているスレッドの数を表す必要がありますか?

コード:

public class MainClass {

public static void main(String[] args) {

    CountDownLatch latch1 = new CountDownLatch(1);
    Thread t1 = new Thread(new AscendingOrder(latch1));
    Thread t2 = new Thread(new DescendingOrder(latch1));

    t1.start();
    t2.start();
}

static class AscendingOrder implements Runnable {

    private CountDownLatch latch;

    public AscendingOrder(CountDownLatch latch) {
        // TODO Auto-generated constructor stub
        this.latch = latch;
    }

    public void run() {
        // TODO Auto-generated method stub
        System.out.println("thread t1 started.");

        for (int i = 0; i < 10; i++)
            System.out.println(i); 

        this.latch.countDown();
    }

}

static class DescendingOrder implements Runnable {

    private CountDownLatch latch;

    public DescendingOrder(CountDownLatch latch1) {
        // TODO Auto-generated constructor stub
        this.latch = latch1;
    }

    public void run() {
        // TODO Auto-generated method stub
        System.out.println("thread t2 started and waiting");

        try {
            this.latch.await();
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        for (int i = 10; i > 0; i--)
            System.out.println(i); 
    }

}

}

4

1 に答える 1

0

1-CountDownLatch と循環バリアを使用してこれを行う方法は?

CyclicBarrier はこの問題には理想的ではありません。この 2 つを比較した記事を書いています。こちらをご覧ください。

public class CountDownLatchTest {

    public static void main(String[] args) {
        CountDownLatch first = new CountDownLatch(1);
        CountDownLatch prev = first;
        for(int i=0;i<10;i++) {
            CountDownLatch next = new CountDownLatch(1);
            new TestThread(prev, next, i).start();
            prev = next;
        }       
        first.countDown();

    }

    public static class TestThread extends Thread {

        private CountDownLatch prev;
        private CountDownLatch next;
        private int id;

        public TestThread(CountDownLatch prev, CountDownLatch next, int id) {
            this.prev = prev;
            this.next = next;
            this.id = id;
        }

        public void run() {
            if (prev != null) {
                try {
                    prev.await();
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            try {
                doWork();
            } finally {
                if (next != null) {
                    next.countDown();
                }
            }
        }

        public void doWork() {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println("Work done in Thread : "
                    + id);
        }

    }
}

2- CountDownLatch クラスのコンストラクタに渡される countDown パラメータは、待機しているスレッドの数を表す必要がありますか?

CountDownLatch.await() は、CountDownLatch.countDown() メソッドが countDown パラメータの回数呼び出されるまで待機します。

于 2015-04-03T08:36:05.360 に答える