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

  • 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();
}
}
}

波比源码 – 精品源码模版分享 | www.bobi11.com
1. 本站所有资源来源于用户上传和网络,如有侵权请邮件联系站长!
2. 分享目的仅供大家学习和交流,您必须在下载后24小时内删除!
3. 不得使用于非法商业用途,不得违反国家法律。否则后果自负!
4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!
5. 如有链接无法下载、失效或广告,请联系管理员处理!
6. 本站资源售价只是赞助,收取费用仅维持本站的日常运营所需!
7. 如遇到加密压缩包,请使用WINRAR解压,如遇到无法解压的请联系管理员!

波比源码 » java多线程――线程间通信之线程等待唤醒机制

发表评论

Hi, 如果你对这款模板有疑问,可以跟我联系哦!

联系站长
赞助VIP 享更多特权,建议使用 QQ 登录
喜欢我嘛?喜欢就按“ctrl+D”收藏我吧!♡