Java怎么創建兩個線程模擬對話

本篇內容主要講解“Java怎么創建兩個線程模擬對話”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“Java怎么創建兩個線程模擬對話”吧!

代碼內容

消費者，負責取走生產者產生的信息

/** * @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怎么創建兩個線程模擬對話”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！