這篇文章將為大家詳細講解有關Java中如何實現多線程通信，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。

在贊皇等地區，都構建了全面的區域性戰略布局，加強發展的系統性、市場前瞻性、產品創新能力，以專注、極致的服務理念，為客戶提供成都網站建設、網站建設 網站設計制作按需求定制制作,公司網站建設,企業網站建設,高端網站設計,營銷型網站建設,外貿營銷網站建設,贊皇網站建設費用合理。

1、共享變量

線程間通信可以通過發送信號，發送信號的一個簡單方式是在共享對象的變量里設置信號值。線程A在一個同步塊里設置boolean型成員變量hasDataToProcess為true，線程B也在同步代碼塊里讀取hasDataToProcess這個成員變量。這個簡單的例子使用了一個持有信號的對象，并提供了set和get方法。

public class MySignal1 {  //共享的變量  private boolean hasDataToProcess = false;  //取值  public boolean getHasDataProcess() {    return hasDataToProcess;  }  //存值  public void setHasDataToProcess(boolean hasDataToProcess) {    this.hasDataToProcess = hasDataToProcess;  }  public static void main(String[] args) {    //同一個對象    final MySignal1 my = new MySignal1();    //線程1設置hasDataToProcess值為true    final Thread t1 = new Thread(new Runnable() {      @Override      public void run() {        my.setHasDataToProcess(true);      }    });    t1.start();    //線程2取這個值hasDataToProcess    Thread t2 = new Thread(new Runnable() {      @Override      public void run() {        try {          //等待線程1完成后取值          t1.join();        } catch (InterruptedException e) {          e.printStackTrace();        }        my.getHasDataProcess();        System.out.println("t1改變以后的值："+my.getHasDataProcess());      }    });    t2.start();  }}

運行結果如下：

t1改變以后的值：true

2、等待/喚醒(wait/notify)機制

以資源為例，生產者生產一個資源，通知消費者就消費掉一個資源，生產者繼續生產資源，消費者消費資源，以此循環，代碼如下。

import sun.security.util.Password;//資源類class Resource {  private String name;  private int count = 1;  private boolean flag = false;  public synchronized void set(String name) {    //生產資源    while (flag) {      try {        //線程等待        wait();      } catch (InterruptedException e) {      }    }    this.name = name + "----" + count + "+++++";    System.out.println(Thread.currentThread().getName() + "..生產者..." + this.name);    flag = true;    //喚醒等待中的消費者    this.notifyAll();  }  public synchronized void out() {    //消費資源    while (!flag) {      try {        //線程等待，生產者生產資源        wait();      } catch (InterruptedException e) {      }    }    System.out.println(Thread.currentThread().getName() + "...消費者..." + this.name);    flag = false;    //喚醒消費者，生產資源    this.notifyAll();  }}//生產者class Producer implements Runnable {  private Resource rs;  public Producer(Resource rs) {    this.rs = rs;  }  //生產者生產資源  @Override  public void run() {    while (true) {      rs.set("商品");    }  }}//消費者消費資源class Consumer implements Runnable {  private Resource rs;  public Consumer(Resource rs) {    this.rs = rs;  }  //消費者消費資源  @Override  public void run() {    while (true) {      rs.out();    }  }}public class ProducerConsumerDemo {  public static void main(String[] args) {    Resource r = new Resource();    Producer p = new Producer(r);    Consumer c = new Consumer(r);    Thread t1 = new Thread(p);    Thread t2 = new Thread(c);    t1.start();    t2.start();  }}

運行結果如下：

Thread-0..生產者...商品----1+++++Thread-1...消費者...商品----1+++++Thread-0..生產者...商品----1+++++Thread-1...消費者...商品----1+++++Thread-0..生產者...商品----1+++++Thread-1...消費者...商品----1+++++Thread-0..生產者...商品----1+++++

關于Java中如何實現多線程通信就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。

分享名稱：Java中如何實現多線程通信-創新互聯
網頁路徑：http://m.newbst.com/article40/dhcsho.html

成都網站建設公司_創新互聯，為您提供關鍵詞優化、品牌網站制作、網站收錄、外貿建站、網頁設計公司、網站策劃

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯