惜- 2021-04-18 15:37 采纳率: 100%
浏览 19
已结题

通知唤醒其他线程时,感觉像锁死了一样

这个代码在通知唤醒时怎么感觉像是锁死了
输出语句就一句


public class Test5 {
    public static void main(String[] args) {
        Data2 data = new Data2();
        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                try {
                    data.printA();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

        }, "A").start();

        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                try {
                    data.printB();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

        }, "B").start();
        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                try {
                    data.printC();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

        }, "C").start();
        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                try {
                    data.printD();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

        }, "D").start();

    }


}

//判断等待-业务计算-通知
class Data2 {
    private int num=0;
   private  Lock lock=new ReentrantLock();
   private  Condition condition=lock.newCondition();
    private  Condition condition2=lock.newCondition();
    private  Condition condition3=lock.newCondition();
    private  Condition condition4=lock.newCondition();
    public synchronized void printA() throws InterruptedException {
        lock.lock();
        try {
            while (num != 0) {//防止虚假唤醒
                condition.await();//等待
            }
            System.out.println(Thread.currentThread().getName() + "->"+"A" + num);
            num=1;
            condition2.signal();//通知
        }
        finally {
            lock.unlock();
        }

    }
    public synchronized void printB() throws InterruptedException {
        lock.lock();
        try {
            while (num != 1) {
                condition2.await();//等待
            }
            System.out.println(Thread.currentThread().getName() + "->"+"B" + num);
            num=2;
            condition3.notify();//通知
        }

    finally {
            lock.unlock();
        }
        }
    public synchronized void printC() throws InterruptedException {
        lock.lock();
        try {
            while (num != 2) {
                condition3.await();//等待
            }
            System.out.println(Thread.currentThread().getName() + "->"+"C" + num);
            num=3;
            condition4.notify();//通知
        }

        finally {
            lock.unlock();
        }
    }
    public synchronized void printD() throws InterruptedException {
        lock.lock();
        try {
            while (num != 3) {
                condition4.await();//等待
            }
            System.out.println(Thread.currentThread().getName() + "->"+"D" + num);
            num=4;
            condition.notify();//通知
        }

        finally {
            lock.unlock();
        }
    }
}
  • 写回答

4条回答 默认 最新

  • 关注

    await改为wait试试

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)

报告相同问题?

问题事件

  • 系统已结题 3月18日
  • 已采纳回答 3月10日

悬赏问题

  • ¥20 西门子S7-Graph,S7-300,梯形图
  • ¥50 用易语言http 访问不了网页
  • ¥50 safari浏览器fetch提交数据后数据丢失问题
  • ¥15 matlab不知道怎么改,求解答!!
  • ¥15 永磁直线电机的电流环pi调不出来
  • ¥15 用stata实现聚类的代码
  • ¥15 请问paddlehub能支持移动端开发吗?在Android studio上该如何部署?
  • ¥20 docker里部署springboot项目,访问不到扬声器
  • ¥15 netty整合springboot之后自动重连失效
  • ¥15 悬赏!微信开发者工具报错,求帮改