Java怎么創(chuàng)建兩個(gè)線程模擬對(duì)話

本篇內(nèi)容主要講解“Java怎么創(chuàng)建兩個(gè)線程模擬對(duì)話”，感興趣的朋友不妨來(lái)看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來(lái)帶大家學(xué)習(xí)“Java怎么創(chuàng)建兩個(gè)線程模擬對(duì)話”吧!

代碼內(nèi)容

消費(fèi)者，負(fù)責(zé)取走生產(chǎn)者產(chǎn)生的信息

/** * @auther:：9527 * @Description: 消費(fèi)者 * @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() {    //循環(huán)顯示50次電影信息    for (int i = 0; i <1000 ; i++) {      try {        Thread.sleep(100);      } catch (InterruptedException e) {        e.printStackTrace();      }      this.mid.get();    }  }}

生產(chǎn)者，負(fù)責(zé)生產(chǎn)信息

/** * @auther:：9527 * @Description: * @program: 多線程 * @create: 2019-08-10 10:39 */public class Producer implements Runnable{  //生產(chǎn)數(shù)據(jù)  private MiddleMan mid = null;  private boolean flag = false;  public Producer(MiddleMan movie) {    this.mid = movie;  }  public Producer() {  }  @Override  public void run() {    //循環(huán)錄入,兩部電影交替錄人    for (int i = 0; i <1000; i++) {      if (flag){        this.mid.set("jack說(shuō)：","我是查水表");        flag = false;      } else {        this.mid.set("rose說(shuō)：","你是誰(shuí)??？");        flag = true;      }    }  }}

信息中轉(zhuǎn)場(chǎng)地 負(fù)責(zé)控制生產(chǎn)和消費(fèi)的節(jié)奏

package com.duo;/** * @auther:：9527 * @Description: 生產(chǎn)者和消費(fèi)者 * @program: 多線程 * @create: 2019-08-10 10:36 */public class MiddleMan {  private String name;  private String info;  private boolean flag = true; //設(shè)置標(biāo)志位，控制生產(chǎn)者生產(chǎn)，消費(fèi)者消費(fèi)  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();  //當(dāng)前線程等待      } catch (InterruptedException e) {        e.printStackTrace();      }    }      this.name = name;    try {      Thread.sleep(100);    } catch (InterruptedException e) {      e.printStackTrace();    }      this.info = info;    flag = false;  //重置標(biāo)志位，讓消費(fèi)者消費(fèi)    super.notify(); //使用Object的notify方法，讓消費(fèi)者線程被喚醒  }  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: 測(cè)試類 * @program: 多線程 * @create: 2019-08-10 11:47 */public class Test {  public static void main(String[] args) {    //生產(chǎn)===>>拿走  生產(chǎn)出來(lái)就被拿走    MiddleMan mid = new MiddleMan();    Thread producer = new Thread(new Producer(mid));    Thread consumer = new Thread(new Consumer(mid));    producer.start();    consumer.start();  }}

到此，相信大家對(duì)“Java怎么創(chuàng)建兩個(gè)線程模擬對(duì)話”有了更深的了解，不妨來(lái)實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！