怎么在Java中创建两个线程模拟对话

怎么在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中创建两个线程模拟对话的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注亿速云行业资讯频道，感谢各位的阅读！