2个线程A-B-A-B或者B-A-B-A循环输出

Posted 2020-10-29 qfxydtk

代码：

/**
 * 两个线程循环打印输出a-b-a-b
 */
public class AandBforTOthread {
    private static Object o = new Object();
    private static int flag=0;
    private static boolean close=false;
    static class A implements Runnable {
        @Override
        public void run() {
            synchronized (o) {
                if (flag==0){
                    flag=1;
                }
                while (!close) {
                    System.out.println("A");
                    if (flag==1){
                        try {
                            o.wait();//释放锁
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        o.notify();
                    }else {
                        o.notify();
                        try {
                            o.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }

                }
                o.notify();
            }
        }
    }

    static class B implements Runnable {
        @Override
        public void run() {
            if (flag==0){
                flag=2;
            }
            synchronized (o) {
                while (!close) {
                    System.out.println("B");
                    if (flag==1){
                        o.notify();
                        try {
                            o.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }else{
                        try {
                            o.wait();//释放锁
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        o.notify();
                    }
                }
                o.notify();
            }
        }
    }

    public static void main(String[] args) {
        Thread a = new Thread(new A());
        Thread b = new Thread(new B());
        b.start();
        a.start();
        try {
            Thread.sleep(10l);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        close=true;
        a.interrupt();
        b.interrupt();
    }
}

　　输出：