十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
本篇内容主要讲解“Java怎么创建两个线程模拟对话”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Java怎么创建两个线程模拟对话”吧!
10年积累的成都网站建设、做网站经验,可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你,你也不认识我。但先网站制作后付款的网站建设流程,更有抚顺免费网站建设让你可以放心的选择与我们合作。
代码内容
消费者,负责取走生产者产生的信息
/** * @auther::9527 * @Description: 消费者 * @program: 多线程 * @create: 2019-08-10 10:45 */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(); } }}
生产者,负责生产信息
/** * @auther::9527 * @Description: * @program: 多线程 * @create: 2019-08-10 10:39 */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;/** * @auther::9527 * @Description: 生产者和消费者 * @program: 多线程 * @create: 2019-08-10 10:36 */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(); //唤醒线程 }}
程序入口
/** * @auther::9527 * @Description: 测试类 * @program: 多线程 * @create: 2019-08-10 11:47 */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怎么创建两个线程模拟对话”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!