一说到线程通信我们就会想到生产者和消费者,哲学家就餐问题,下面例子是以生产者与消费者来实现线程之间的通信
package com.lamp.test;
public class Cake {
private int number = 0;
public synchronized void increase(){
while(0 != number){ //如果只有一个生产者进程和一个消费者进程,我们还可以用if来判断,但是涉及到2个以上进程就需用while来判断了这也是实践中用的最多的
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
number++; //假定资源的数量只能为0或者1,为0时加1并唤醒消费者进程,消费者进程相反
System.out.println(number);
this.notify();
}
public synchronized void decrease(){
while(0 == number){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
number--;
System.out.println(number);
this.notify();
}
}
生产者进程类
package com.lamp.test;
public class Producer extends Thread {
private Cake cake;
public Producer(Cake cake) {
this.cake = cake;
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
try {
Thread.sleep((long) (Math.random() * 1000));
} catch (InterruptedException e) {
e.printStackTrace();
}
this.cake.increase();
}
}
}
消费者进程类
package com.lamp.test;
public class Consumer extends Thread{
private Cake cake = null;
public Consumer(Cake cake) {
this.cake = cake;
}
@Override
public void run(){
for(int i=0; i<10; i++){
try {
Thread.sleep((long) (Math.random() * 1000));
} catch (InterruptedException e) {
e.printStackTrace();
}
this.cake.decrease();
}
}
}
写个测试类
package com.lamp.test;
public class CakeTest {
public static void main(String[] args) {
Cake cake = new Cake();
Thread t1 = new Producer(cake);
Thread t2 = new Consumer(cake); //确保访问的是同一资源
Thread t3 = new Producer(cake);
Thread t4 = new Consumer(cake);
t1.start();
t2.start();
t3.start();
t4.start();
}
}
wait与notify方法都是定义在Object方法中,而且是final的,因此会被所有的java类继承但是不能重写,这两个方法的调用必须在synchronized方法或者synchronized块中,而且当前线程要已经拿到了对象锁,当线程执行wait方法时,它会释放对象锁
分享到:
相关推荐
Java 线程通信示例 源代码 多线程之间通信,值得收藏
主要介绍了JAVA 线程通信相关知识,文中讲解非常细致,代码帮助大家更好的理解和学习,感兴趣的朋友可以了解下
本源代码是博客《Java 多线程编程之六:线程之间的通信(附源代码)》附带的实例性源代码。原博客链接地址:http://blog.csdn.net/defonds/archive/2010/01/26/5257301.aspx。
线程通信,采用java技术,实现线程之间的通信。
开发中不免会遇到需要所有子线程执行完毕通知主线程处理某些逻辑的场景。或者是线程 A 在执行到某个条件通知线程 B 执行某个操作。下面我们来一起学习如何解决吧
主要介绍了Java 线程通信的的相关资料,文中讲解非常细致,代码帮助大家更好的理解和学习,感兴趣的朋友可以了解下
关于java 中的多线程,很多初学者为之头疼,看了一些书后,编了几个小程序,发布到这,希望有用!
java 多线程 其实就是每个线程都拥有自己的内存空间,多线程之间的通信,比例A线程修改了主内存(main方法的线程)变量,需要把A线程修改的结果同步到主线程中,这时B线程再从主线程获取该变量的值,这样就实现了...
本篇文章主要介绍了Java线程通信问题,线程通信用来保证线程协调运行,有需要的朋友可以了解一下。
主要为大家详细介绍了Java线程间的通信方式,以代码结合文字的方式来讨论线程间的通信,感兴趣的朋友可以参考一下
java tcp socket 多线程多句通信
java ,线程通信安全问题 ,属于入门代码,简单。 不喜勿喷呀。
java线程 线程 教程 java线程教程 java线程学习资料 本教程有什么内容? 本教程研究了线程的基础知识— 线程是什么、线程为什么有用以及怎么开始编写使用线程的简单 程序。 我们还将研究更复杂的、使用线程的应用...
使用wait()和notify()实现的生产者与消费者模型,可以了解如何使用wait()和notify()进行线程间通信。(上一次上传的代码有一个问题没有考虑到,这次修补了——CSDN没法撤销资源,只能再上传了)
Java多线程通信机制研究
java多线程经典案例,线程同步、线程通信、线程阻塞等经典案例
1.线程同步 2.线程间通信 3.线程挂起、恢复和终止 demo演示
Java的多线程-线程间的通信.doc
关于Java线程间通信-回调