這篇文章將為大家詳細(xì)講解有關(guān)Java中如何實(shí)現(xiàn)多線程通信,文章內(nèi)容質(zhì)量較高,因此小編分享給大家做個(gè)參考,希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。
在贊皇等地區(qū),都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局,加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力,以專注、極致的服務(wù)理念,為客戶提供成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè) 網(wǎng)站設(shè)計(jì)制作按需求定制制作,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),高端網(wǎng)站設(shè)計(jì),營(yíng)銷型網(wǎng)站建設(shè),外貿(mào)營(yíng)銷網(wǎng)站建設(shè),贊皇網(wǎng)站建設(shè)費(fèi)用合理。1、共享變量
線程間通信可以通過發(fā)送信號(hào),發(fā)送信號(hào)的一個(gè)簡(jiǎn)單方式是在共享對(duì)象的變量里設(shè)置信號(hào)值。線程A在一個(gè)同步塊里設(shè)置boolean型成員變量hasDataToProcess為true,線程B也在同步代碼塊里讀取hasDataToProcess這個(gè)成員變量。這個(gè)簡(jiǎn)單的例子使用了一個(gè)持有信號(hào)的對(duì)象,并提供了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) { //同一個(gè)對(duì)象 final MySignal1 my = new MySignal1(); //線程1設(shè)置hasDataToProcess值為true final Thread t1 = new Thread(new Runnable() { @Override public void run() { my.setHasDataToProcess(true); } }); t1.start(); //線程2取這個(gè)值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(); }}
運(yùn)行結(jié)果如下:
t1改變以后的值:true
2、等待/喚醒(wait/notify)機(jī)制
以資源為例,生產(chǎn)者生產(chǎn)一個(gè)資源,通知消費(fèi)者就消費(fèi)掉一個(gè)資源,生產(chǎn)者繼續(xù)生產(chǎn)資源,消費(fèi)者消費(fèi)資源,以此循環(huán),代碼如下。
import sun.security.util.Password;//資源類class Resource { private String name; private int count = 1; private boolean flag = false; public synchronized void set(String name) { //生產(chǎn)資源 while (flag) { try { //線程等待 wait(); } catch (InterruptedException e) { } } this.name = name + "----" + count + "+++++"; System.out.println(Thread.currentThread().getName() + "..生產(chǎn)者..." + this.name); flag = true; //喚醒等待中的消費(fèi)者 this.notifyAll(); } public synchronized void out() { //消費(fèi)資源 while (!flag) { try { //線程等待,生產(chǎn)者生產(chǎn)資源 wait(); } catch (InterruptedException e) { } } System.out.println(Thread.currentThread().getName() + "...消費(fèi)者..." + this.name); flag = false; //喚醒消費(fèi)者,生產(chǎn)資源 this.notifyAll(); }}//生產(chǎn)者class Producer implements Runnable { private Resource rs; public Producer(Resource rs) { this.rs = rs; } //生產(chǎn)者生產(chǎn)資源 @Override public void run() { while (true) { rs.set("商品"); } }}//消費(fèi)者消費(fèi)資源class Consumer implements Runnable { private Resource rs; public Consumer(Resource rs) { this.rs = rs; } //消費(fèi)者消費(fèi)資源 @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(); }}
運(yùn)行結(jié)果如下:
Thread-0..生產(chǎn)者...商品----1+++++Thread-1...消費(fèi)者...商品----1+++++Thread-0..生產(chǎn)者...商品----1+++++Thread-1...消費(fèi)者...商品----1+++++Thread-0..生產(chǎn)者...商品----1+++++Thread-1...消費(fèi)者...商品----1+++++Thread-0..生產(chǎn)者...商品----1+++++
關(guān)于Java中如何實(shí)現(xiàn)多線程通信就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到。
分享名稱:Java中如何實(shí)現(xiàn)多線程通信-創(chuàng)新互聯(lián)
網(wǎng)頁路徑:http://jinyejixie.com/article40/dhcsho.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供關(guān)鍵詞優(yōu)化、品牌網(wǎng)站制作、網(wǎng)站收錄、外貿(mào)建站、網(wǎng)頁設(shè)計(jì)公司、網(wǎng)站策劃
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容
營(yíng)銷型網(wǎng)站建設(shè)知識(shí)