1

以下のコードにスレッドのスケルトンがあります。シンプルなカウントダウン ラッチを使用しました。スレッド 2 に応じてスレッド 1 が完了している状況に陥っています。例外がなければ、コードは正しく実行されます。しかし、例外の可能性はもっと高くなります。スレッド 2 またはいずれかのスレッドで例外が発生した場合は、すべてのスレッドの実行を停止する必要があります。私の独立したスレッドは、例外の後でも実行を続けます。また、スレッド 1 でフラグを使用して、スレッド 2 で例外が発生したかどうかを確認しました。例外をテストする例として、ゼロ除算の例外を意図的に配置しました。これに対する解決策が見つかりません。私を助けてください..!

import java.util.concurrent.CountDownLatch;

    public class MainThread extends Thread{
        static boolean flag=false;
        final static CountDownLatch latch1= new CountDownLatch(1);
        final static CountDownLatch latch2= new CountDownLatch(1);
        final static CountDownLatch latch3= new CountDownLatch(3);
        static MainThread t1;
        static MainThread t2;
        static MainThread t3;
        static MainThread t4;
        static MainThread t5;

        public static void main(String args[]){


             t1 = new MainThread(){
                public void run(){


                    System.out.println("Waiting for Thread 2");
                    try {
                        System.out.println("THis iss before the thread 2 starts its for loop.");
                        latch2.countDown();
                        t3.start();
                        t4.start();
                        t5.start();
                        System.out.println("waiting for thread 2 to countdown");
                        latch1.await();
                        if(flag==true){
                            System.out.println("successful.");
                        }
                        else{
                            System.out.println("error.");

                        }
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    System.out.println("All the dependencies resolved.");
                    System.out.println("Waiting for the remaining threads to complete their work.");
                    try {
                        latch3.await();
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    System.out.println("All the threads have finished doing their work. Exiting now...");
                }
            };
            Thread t2 = new MainThread(){
                public void run(){
                    System.out.println("Before Starting for loop");
                    try {

                        System.out.println("waiting for thread 1 to countdown latch2");
                        latch2.await();
                        System.out.println("Starting for loop");
                        for(int i=0;i<5;i++){
                            System.out.println("iteration: "+i);
                            try {
                                Thread.sleep(5);
                            } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                            }
                        }
                        int x=1/0;
                        latch1.countDown();
                        System.out.println("countdown by thread2 for latch 1 done.");

                        flag=true;
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();

                    }
                    finally{
                        latch1.countDown();

                    }
                }
            };
            t3 = new MainThread(){
                public void run(){
                    System.out.println("Running Thread 3");
                    for(int i=0;i<10;i++){
                        System.out.println("iteration: "+i+ " "+t3.getName());
                        try {
                            Thread.sleep(5);
                        } catch (InterruptedException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                    latch3.countDown();

                }
            };

            t4 = new MainThread(){
                public void run(){
                    System.out.println("Running Thread 4");
                    for(int i=0;i<10;i++){
                        System.out.println("iteration: "+i+ " "+t4.getName());
                        try {
                            Thread.sleep(5);
                        } catch (InterruptedException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }

                    latch3.countDown();
                }
            };

            t5 = new MainThread(){
                public void run(){
                    System.out.println("Running Thread 5");
                    for(int i=0;i<10;i++){
                        System.out.println("iteration: "+i+ " "+t5.getName());
                        try {
                            Thread.sleep(5);
                        } catch (InterruptedException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }

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


        }





    }

私の出力は次のとおりです。

Before Starting for loop
waiting for thread 1 to countdown latch2
Waiting for Thread 2
THis iss before the thread 2 starts its for loop.
Starting for loop
iteration: 0
waiting for thread 2 to countdown
Running Thread 3
iteration: 0 Thread-2
Running Thread 5
iteration: 0 Thread-4
Running Thread 4
iteration: 0 Thread-3
iteration: 1
iteration: 1 Thread-3
iteration: 1 Thread-2
iteration: 1 Thread-4
iteration: 2
iteration: 2 Thread-3
iteration: 2 Thread-2
iteration: 2 Thread-4
iteration: 3
iteration: 3 Thread-3
iteration: 3 Thread-2
iteration: 3 Thread-4
iteration: 4
iteration: 4 Thread-3
iteration: 4 Thread-4
iteration: 4 Thread-2
iteration: 5 Thread-3
error.
All the dependencies resolved.
Waiting for the remaining threads to complete their work.
Exception in thread "Thread-1" java.lang.ArithmeticException: / by zero
    at ThreadProjectStructure.MainThread$2.run(MainThread.java:72)
iteration: 5 Thread-4
iteration: 5 Thread-2
iteration: 6 Thread-3
iteration: 6 Thread-4
iteration: 6 Thread-2
iteration: 7 Thread-3
iteration: 7 Thread-2
iteration: 7 Thread-4
iteration: 8 Thread-3
iteration: 8 Thread-2
iteration: 8 Thread-4
iteration: 9 Thread-3
iteration: 9 Thread-4
iteration: 9 Thread-2
All the threads have finished doing their work. Exiting now...
4

3 に答える 3

1

さて、現在のコードでは、視点を正しくする必要があります。自明なラッチ変数を定義してください。そうしないと混乱します。以下が要件であると仮定します。スレッド 2 の実行が成功した場合にのみ、他のスレッドに進みます。

更新されたコードは次のとおりです。

import java.util.concurrent.CountDownLatch;

public class MainThread extends Thread{
    static boolean flag=false;
    final static CountDownLatch waitForThread2ToFinish= new CountDownLatch(1);
    final static CountDownLatch waitForStartSignalFromThread1= new CountDownLatch(1);
    final static CountDownLatch latchForAllOtherThreads= new CountDownLatch(3);
    static MainThread t1;
    static MainThread t2;
    static MainThread t3;
    static MainThread t4;
    static MainThread t5;

    public static void main(String args[]){
        t1 = new MainThread(){
            public void run(){
                try {
                    System.out.println("Waiting for Thread 2 to finish");
                    waitForStartSignalFromThread1.countDown();
                    waitForThread2ToFinish.await();
                    if(flag==true){
                        System.out.println("Successful.");
                        t3.start();
                        t4.start();
                        t5.start();

                        System.out.println("All the dependencies resolved.");
                        System.out.println("Waiting for the remaining threads to complete their work.");
                        try {
                            latchForAllOtherThreads.await();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        System.out.println("All the threads have finished doing their work. Exiting now...");
                    }
                    else{
                        System.out.println("Error.");

                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }
        };
        Thread t2 = new MainThread(){
            public void run(){
                System.out.println("Before Starting for loop");
                try {

                    System.out.println("waiting for thread 1 to countdown latch2");
                    waitForStartSignalFromThread1.await();
                    System.out.println("Starting for loop");
                    for(int i=0;i<5;i++){
                        System.out.println("iteration: "+i);
                        try {
                            Thread.sleep(5);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    int x=1/0;

                    System.out.println("countdown by thread2 for latch 1 done.");

                    flag=true;
                } catch (Exception e) {
                    e.printStackTrace();

                }
                finally{
                    waitForThread2ToFinish.countDown();
                }
            }
        };
        t3 = new MainThread(){
            public void run(){
                System.out.println("Running Thread 3");
                for(int i=0;i<10;i++){
                    System.out.println("iteration: "+i+ " "+t3.getName());
                    try {
                        Thread.sleep(5);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                latchForAllOtherThreads.countDown();

            }
        };

        t4 = new MainThread(){
            public void run(){
                System.out.println("Running Thread 4");
                for(int i=0;i<10;i++){
                    System.out.println("iteration: "+i+ " "+t4.getName());
                    try {
                        Thread.sleep(5);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }

                latchForAllOtherThreads.countDown();
            }
        };

        t5 = new MainThread(){
            public void run(){
                System.out.println("Running Thread 5");
                for(int i=0;i<10;i++){
                    System.out.println("iteration: "+i+ " "+t5.getName());
                    try {
                        Thread.sleep(5);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }

                latchForAllOtherThreads.countDown();
            }
        };
        t1.start();
        t2.start();
    }
}
于 2015-09-02T07:31:14.173 に答える