代码内容

消费者，负责取走生产者产生的信息

/** * @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();  }}