java 中线程等待与通知的实现

java 中线程等待与通知的实现

前言：

关于等待/通知，要记住的关键点是：

必须从同步环境内调用wait()、notify()、notifyAll()方法。线程不能调用对象上等待或通知的方法，除非它拥有那个对象的锁。

wait()、notify()、notifyAll()都是Object的实例方法。与每个对象具有锁一样，每个对象可以有一个线程列表，他们等待来自该信号（通知）。线程通过执行对象上的wait()方法获得这个等待列表。从那时候起，它不再执行任何其他指令，直到调用对象的notify()方法为止。如果多个线程在同一个对象上等待，则将只选择一个线程（不保证以何种顺序）继续执行。如果没有线程等待，则不采取任何特殊操作。

示例代码：

package threadwait;

public class ThreadA extends Thread{

  public int num = 0;

  public void run(){

    synchronized (this){//在此类对象上实现同步，this指代当前对象

      for(int i = 0 ; i < 3 ; ++i)

       this.num+=i;

      notifyAll();//通知所有在这个对象上等待的线程开始执行，在这里就是通知TestNotify主线程开始执行

    }

  }

  public int getNum(){

    return this.num;

  }

}

package threadwait;

 

public class TestNotify{

  public static void main(String args[]){

    ThreadA threada = new ThreadA();

    threada.start();//threada线程有执行的资格，但是还没有开始执行

    synchronized(threada){

      try{

       threada.wait();//主线程等待threada线程执行结束才开始执行

       //而且只有获得了当前threada对象的锁之后才能执行wait，就是说在同步域内才可以执行wait，执行wait后放弃对象锁

      }catch(InterruptedException e){

       e.printStackTrace();

      }

    }

    System.out.println(threada.getNum());

  }

}

同步可以是在class级别上的，synchronized(A.class)，也可以是在对象级别上的synchronized(this),可以是静态同步方法，static synchronized ,静态同步方法是在class级别上的，非静态同步方法是在类对象级别上的，一个类对象只有一个锁，只有获得了该锁才可以对他执行wait操作，后释放掉该锁。

更进一步的实例代码如下：

package threadwait;

 

public class ThreadA extends Thread{

  public int num = 0;

  public void run(){

    synchronized (this){//在此类对象上实现同步，this指代当前对象

      for(int i = 0 ; i < 3 ; ++i)

       this.num+=i;

      try{

       Thread.sleep(500);//如果ThreadB的三个示例线程在还没有进入等待状态之前就受到了notifyall的信号

       //那将会发生严重后果，因为调用notifyall的线程只可以调用一次notifyall，那造成等待的线程将永远等待下去

       //所以在此处让它睡一小会，让其他线程有时间进入等待状态。

       //不然会收到

      }catch(InterruptedException e){

       e.printStackTrace();

      }

      notifyAll();//通知所有在这个对象上等待的线程开始执行，在这里就是通知TestNotify主线程开始执行

    }

//   notifyAll();

  }

  public int getNum(){

    return this.num;

  }

}

package threadwait;

 

public class ThreadB extends Thread{

  private ThreadA threada;

  public ThreadB(ThreadA ta){

    this.threada = ta;

  }

  public void run(){

    System.out.println(Thread.currentThread().getName()+" is waitting.");

    synchronized(threada){

      try{

       threada.wait();

      }catch(InterruptedException e){

       e.printStackTrace();

      }

      System.out.println(Thread.currentThread().getName()+" "+this.threada.getNum());

    }

   

  }

}

package threadwait;

 

public class TestNotify{

  public static void main(String args[]){

    ThreadA threada = new ThreadA();

    new ThreadB(threada).start();

    new ThreadB(threada).start();

    new ThreadB(threada).start();

    threada.start();

  }

}

如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# java # 中线程等待与通知 # java线程中等待与通知的实现 # java基本教程之java线程等待与java唤醒线程 java多线程教程 # Java多线程--让主线程等待所有子线程执行完毕在执行 # 详解java中的互斥锁信号量和多线程等待机制 # java线程同步操作实例详解 # Java多线程死锁示例 # Java线程同步方法实例总结 # Java线程关闭的3种方法 # Java多线程实现异步调用的方法 # Java线程中sleep和wait的区别详细介绍 # 图解Java线程的生命周期 # Java线程等待用法实例分析 # 是在 # 在这里 # 还没有 # 在这个 # 才可以 # 此类 # 都是 # 获得了 # 多个 # 将会 # 如有 # 对他 # 希望能 # 如果没有 # 那时候 # 只有一个 # 让它 # 谢谢大家 # 前就 # 要记住

返回目录在线咨询

上一篇：快速收录与网站流量之间的关系是什么_SEO优化教程
下一篇：php常量怎么用_PHP常量（define/const）定义与使用方法

您的项目需求

*请认真填写需求信息，我们会在24小时内与您取得联系。

全网整合营销服务商

java 中线程等待与通知的实现

您的项目需求