我有 3 个线程 第一次打印 A 第二次打印 B 第三次打印C

我想按顺序打印 A B C A B C A B C 等等......

所以我写了下面的程序，但我没能达到同样的效果。 我知道这个问题，当 status=1 时，例如 B1 和 C1 线程正在等待，当我执行 notifyAll() 时，两个等待线程都会唤醒，并且根据 CPU 分配，它可能会打印 B 或 C。

在这种情况下，我只想在 A 之后打印 B。

我需要做什么修改。

public class NotifyAllExample {

    int status=1;
    public static void main(String[] args) {

        NotifyAllExample notifyAllExample = new NotifyAllExample();

        A1 a=new A1(notifyAllExample);
        B1 b=new B1(notifyAllExample);
        C1 c=new C1(notifyAllExample);

        a.start();
        b.start();
        c.start();
    }
}

class A1 extends Thread{
    NotifyAllExample notifyAllExample;

    A1(NotifyAllExample notifyAllExample){
        this.notifyAllExample = notifyAllExample;
    }

    @Override
    public void run() {

        try{
            synchronized (notifyAllExample) {

                for (int i = 0; i < 100; i++) {

                    if(notifyAllExample.status!=1){
                        notifyAllExample.wait();
                    }

                    System.out.print("A ");
                    notifyAllExample.status = 2;
                    notifyAllExample.notifyAll();
                }

            }
        }catch (Exception e) {
            System.out.println("Exception 1 :"+e.getMessage());
        }

    }

}

class B1 extends Thread{

    NotifyAllExample notifyAllExample;

    B1(NotifyAllExample notifyAllExample){
        this.notifyAllExample = notifyAllExample;
    }

    @Override
    public void run() {

        try{
            synchronized (notifyAllExample) {

                for (int i = 0; i < 100; i++) {

                    if(notifyAllExample.status!=2){
                        notifyAllExample.wait();
                    }

                    System.out.print("B ");
                    notifyAllExample.status = 3;
                    notifyAllExample.notifyAll();
                }

            }
        }catch (Exception e) {
            System.out.println("Exception 2 :"+e.getMessage());
        }

    }
}


class C1 extends Thread{

    NotifyAllExample notifyAllExample;

    C1(NotifyAllExample notifyAllExample){
        this.notifyAllExample = notifyAllExample;
    }

    @Override
    public void run() {

        try{
            synchronized (notifyAllExample) {

                for (int i = 0; i < 100; i++) {

                    if(notifyAllExample.status!=3){
                        notifyAllExample.wait();
                    }

                    System.out.print("C ");
                    notifyAllExample.status = 1;
                    notifyAllExample.notifyAll();
                }

            }
        }catch (Exception e) {
            System.out.println("Exception 3 :"+e.getMessage());
        }

    }
}

最佳答案

将这些 IF 语句转换为 WHILE 语句以获得所需的行为:

if (notifyAllExample.status != 2){
    notifyAllExample.wait();
}

到

while (notifyAllExample.status != 2){
    notifyAllExample.wait();
}

这将确保如果一个线程收到通知，它不会退出 while 循环，直到状态值达到它所期望的值。

此外，将 status 标记为易变的，这样线程就没有本地副本。

关于java - 按顺序运行3个线程java，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/12989397/