Java中如何實(shí)現(xiàn)多線程通信-創(chuàng)新互聯(lián)

這篇文章將為大家詳細(xì)講解有關(guān)Java中如何實(shí)現(xiàn)多線程通信，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。

在贊皇等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒ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ì),營銷型網(wǎng)站建設(shè),外貿(mào)營銷網(wǎng)站建設(shè),贊皇網(wǎng)站建設(shè)費(fèi)用合理。

1、共享變量

線程間通信可以通過發(fā)送信號，發(fā)送信號的一個(gè)簡單方式是在共享對象的變量里設(shè)置信號值。線程A在一個(gè)同步塊里設(shè)置boolean型成員變量hasDataToProcess為true，線程B也在同步代碼塊里讀取hasDataToProcess這個(gè)成員變量。這個(gè)簡單的例子使用了一個(gè)持有信號的對象，并提供了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è)對象 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)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。

分享名稱：Java中如何實(shí)現(xiàn)多線程通信-創(chuàng)新互聯(lián)
網(wǎng)頁路徑：http://www.muchs.cn/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)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容