怎么在Java中创建两个线程模拟对话?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
需求说明
实现方式
嗯 这个可以视作一个经典的消费者和生产者的问题,详细见代码注释
代码内容
消费者,负责取走生产者产生的信息
public class Consumer extends Thread{
private MiddleMan mid = null;
public Consumer() {
}
public Consumer(MiddleMan movie) {
this.mid = movie;
}
@Override
public void run() {
//循环显示50次电影信息
for (int i = 0; i <1000 ; i++) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
this.mid.get();
}
}
}
生产者,负责生产信息
public class Producer implements Runnable{
//生产数据
private MiddleMan mid = null;
private boolean flag = false;
public Producer(MiddleMan movie) {
this.mid = movie;
}
public Producer() {
}
@Override
public void run() {
//循环录入,两部电影交替录人
for (int i = 0; i <1000; i++) {
if (flag){
this.mid.set("jack说:","我是查水表");
flag = false;
} else {
this.mid.set("rose说:","你是谁啊?");
flag = true;
}
}
}
}
信息中转场地 负责控制生产和消费的节奏
package com.duo;
public class MiddleMan {
private String name;
private String info;
private boolean flag = true; //设置标志位,控制生产者生产,消费者消费
public String getName() {
return name;
}
public String getInfo() {
return info;
}
public MiddleMan(String name, String info) {
this.name = name;
this.info = info;
}
public MiddleMan() {
}
public synchronized void set(String name,String info){
if (!flag){
try {
super.wait(); //当前线程等待
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.name = name;
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
this.info = info;
flag = false; //重置标志位,让消费者消费
super.notify(); //使用Object的notify方法,让消费者线程被唤醒
}
public synchronized void get(){
if (flag){
try {
super.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(this.getName()+"-"+this.getInfo());
flag = true;
super.notify(); //唤醒线程
}
}
程序入口
public class Test {
public static void main(String[] args) {
//生产===>>拿走 生产出来就被拿走
MiddleMan mid = new MiddleMan();
Thread producer = new Thread(new Producer(mid));
Thread consumer = new Thread(new Consumer(mid));
producer.start();
consumer.start();
}
}
运行结果
看完上述内容,你们掌握怎么在Java中创建两个线程模拟对话的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注亿速云行业资讯频道,感谢各位的阅读!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。