Java多執行緒通訊實現方式詳解
阿新 • • 發佈:2020-01-07
這篇文章主要介紹了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+++++
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。