zoukankan      html  css  js  c++  java
  • java基础-多线程 等待唤醒机制

     
     /**
      * @param args
      * 等待唤醒机制
      */
     public static void main(String[] args) {
      final Printer p = new Printer();
      
      new Thread() {
       public void run() {
        while(true) {
         try {
          p.print1();
         } catch (InterruptedException e) {
          
          e.printStackTrace();
         }
        }
       }
      }.start();
      
      new Thread() {
       public void run() {
        while(true) {
         try {
          p.print2();
         } catch (InterruptedException e) {
          
          e.printStackTrace();
         }
        }
       }
      }.start();
     }
    }
    //等待唤醒机制
    class Printer {
     private int flag = 1;
     public void print1() throws InterruptedException {       
      synchronized(this) {
       if(flag != 1) {
        this.wait();     //当前线程等待
       }
       System.out.print("程");
       System.out.print("序");
       System.out.print("员");
       System.out.print(" ");
       flag = 2;
       this.notify();      //随机唤醒单个等待的线程
      }
     }
     
     public void print2() throws InterruptedException {
      synchronized(this) {
       if(flag != 2) {
        this.wait();
       }
       System.out.print("传");
       System.out.print("播");
       System.out.print(" ");
       flag = 1;
       this.notify();
      }
     }
     
     
     
    /////////////////////////////**********************************
     /**
      * @param args
      */
     public static void main(String[] args) {
      final Printer2 p = new Printer2();
      new Thread() {
       public void run() {
        while(true) {
         try {
          p.print1();
         } catch (InterruptedException e) {
          
          e.printStackTrace();
         }
        }
       }
      }.start();
      
      new Thread() {
       public void run() {
        while(true) {
         try {
          p.print2();
         } catch (InterruptedException e) {
          
          e.printStackTrace();
         }
        }
       }
      }.start();
      
      new Thread() {
       public void run() {
        while(true) {
         try {
          p.print3();
         } catch (InterruptedException e) {
          
          e.printStackTrace();
         }
        }
       }
      }.start();
     }
    }
    /*1,在同步代码块中,用哪个对象锁,就用哪个对象调用wait方法
     * 2,为什么wait方法和notify方法定义在Object这类中?
     *  因为锁对象可以是任意对象,Object是所有的类的基类,所以wait方法和notify方法需要定义在Object这个类中
     * 3,sleep方法和wait方法的区别?
     * a,sleep方法必须传入参数,参数就是时间,时间到了自动醒来
     *   wait方法可以传入参数也可以不传入参数,传入参数就是在参数的时间结束后等待,不传入参数就是直接等待
     * b,sleep方法在同步函数或同步代码块中,不释放锁,睡着了也抱着锁睡
     *  wait方法在同步函数或者同步代码块中,释放锁
     */
    class Printer2 {
     private int flag = 1;
     public void print1() throws InterruptedException {       
      synchronized(this) {
       while(flag != 1) {
        this.wait();     //当前线程等待
       }
       System.out.print("程");
       System.out.print("序");
       System.out.print("员");
       System.out.print(" ");
       flag = 2;
       //this.notify();      //随机唤醒单个等待的线程
       this.notifyAll();
      }
     }
     
     public void print2() throws InterruptedException {
      synchronized(this) {
       while(flag != 2) {
        this.wait();     //线程2在此等待
       }
       System.out.print("传");
       System.out.print("播");
       System.out.print(" ");
       flag = 3;
       //this.notify();
       this.notifyAll();
      }
     }
     
     public void print3() throws InterruptedException {
      synchronized(this) {
       while(flag != 3) {
        this.wait();      //线程3在此等待,if语句是在哪里等待,就在哪里起来
                 //while循环是循环判断,每次都会判断标记
       }
       System.out.print("i");
       System.out.print("t")
       System.out.print("i");
       System.out.print("m");
       System.out.print("a");
       System.out.print(" ");
       flag = 1;
       //this.notify();
       this.notifyAll();
      }
     }
    }
     
     
  • 相关阅读:
    前端周刊第一期
    Java CAS 原理详解
    【转载】Linux系统调用SYSCALL_DEFINE详解
    简述伪共享和缓存一致性MESI
    exchange发邮件
    Flutter屏幕适配(自适应)方案
    dart类初始化 future方案
    windows下postgresql自启动
    How can I call an async method in StatelessWidget.build method?
    实战分层架构
  • 原文地址:https://www.cnblogs.com/wuxu/p/10722384.html
Copyright © 2011-2022 走看看