程序员人生 网站导航

java多线程――线程间通信之线程等待唤醒机制

栏目:php教程时间:2015-04-20 08:04:55
  • 3个方法
    wait()
    notify()
    notifyAll()
    3个方法都使用在同步中,由于要对持有锁(又叫监控)的线程操作。
    所以要使用在同步中,由于只有同步才具有锁。
  • 为何这些操作线程的方法均出现在Object类中?
    由于这些方法在操作同步中的线程时候,都必须要标识所操作线程识有锁。只有同1个锁上的被等待的线程,可以被同1个锁上的notify唤醒,不可以对不同锁中的线程进行唤醒。
    也就是说,等待和唤醒必须是同1个锁。
public class Demo1 { public static void main(String[] args) { Res res = new Res(); Input i = new Input(res); Output o = new Output(res); Thread t1 = new Thread(i); Thread t2 = new Thread(o); t1.start(); t2.start(); } } class Res { private String name; private String gender; private boolean flag; public synchronized void setNameGender(String name, String gender) { if (flag) try { this.wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } this.name = name; this.gender = gender; this.flag = true; this.notify(); } public synchronized void out() { if (!this.flag) try { this.wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println(this.name + " : " + this.gender); this.flag = false; this.notify(); } } class Input implements Runnable { private Res res; Input(Res res) { this.res = res; } public void run() { int x = 0; while (true) { if (x % 3 == 0) { res.setNameGender("T-mac", "male"); } else if (x % 3 == 1) { res.setNameGender("麦迪", "男人"); } else { res.setNameGender("CBA", "糟"); } x++; } } } class Output implements Runnable { private Res res; Output(Res res) { this.res = res; } public void run() { while (true) { res.out(); } } }
------分隔线----------------------------
------分隔线----------------------------

最新技术推荐