欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java實(shí)現(xiàn)線(xiàn)程通信的案例講解

 更新時(shí)間:2022年05月26日 14:17:08   作者:遇安.112  
所謂線(xiàn)程通信就是線(xiàn)程間相互發(fā)送數(shù)據(jù),線(xiàn)程通信通常通過(guò)共享一個(gè)數(shù)據(jù)的方式實(shí)現(xiàn)。本文將通過(guò)案例詳解Java中線(xiàn)程通信的實(shí)現(xiàn),感興趣的可以了解一下

什么是線(xiàn)程通信、如何實(shí)現(xiàn)?

所謂線(xiàn)程通信就是線(xiàn)程間相互發(fā)送數(shù)據(jù),線(xiàn)程通信通常通過(guò)共享一個(gè)數(shù)據(jù)的方式實(shí)現(xiàn)。

線(xiàn)程間會(huì)根據(jù)共享數(shù)據(jù)的情況決定自己該怎么做,以及通知其他線(xiàn)程怎么做。

線(xiàn)程通信常見(jiàn)模型

生產(chǎn)者與消費(fèi)者模型:生產(chǎn)者線(xiàn)程負(fù)責(zé)生產(chǎn)數(shù)據(jù),消費(fèi)者線(xiàn)程負(fù)責(zé)消費(fèi)數(shù)據(jù)。

要求:生產(chǎn)者線(xiàn)程生產(chǎn)完數(shù)據(jù)后,喚醒消費(fèi)者,然后等待自己;消費(fèi)者消費(fèi)完該數(shù)據(jù)后,喚醒生產(chǎn)者,然后等待自己

public class 多線(xiàn)程_5線(xiàn)程通信 extends Thread{
 
    public static void main(String[] args) {
        //定義線(xiàn)程類(lèi),創(chuàng)建一個(gè)共享的賬戶(hù)對(duì)象
        account3 a=new account3("abc",0);
        //創(chuàng)建兩個(gè)取錢(qián)的線(xiàn)程對(duì)象
        new drawthread3(a,"小明").start();
        new drawthread3(a,"小紅").start();
        //創(chuàng)建三個(gè)存錢(qián)的線(xiàn)程對(duì)象
        new savethread(a,"存錢(qián)罐1號(hào)").start();
        new savethread(a,"存錢(qián)罐2號(hào)").start();
        new savethread(a,"存錢(qián)罐3號(hào)").start();
    }
}
//存錢(qián)的線(xiàn)程類(lèi)
class savethread extends Thread{
    //接收處理的賬戶(hù)對(duì)象
    private account3 acc;
    public savethread(account3 acc,String name){
        super(name);
        this.acc=acc;
    }
    public void run(){
        try {
            while (true){
                //存錢(qián)
                acc.savemoney(100000);
                //休眠2秒
                Thread.sleep(2000);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
//取錢(qián)的線(xiàn)程類(lèi)
class drawthread3 extends Thread{
    //接收處理的賬戶(hù)對(duì)象
    private account3 acc;
    public drawthread3(account3 acc,String name){
        super(name);
        this.acc=acc;
    }
    public void run(){
        try {
            while (true){
                //取錢(qián)
                acc.drawmoney3(100000);
                //休眠2秒
                Thread.sleep(2000);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
class account3{
    private String cartId;
    private double money;//賬戶(hù)余額
 
    public account3() {
    }
 
    public account3(String cartId, double money) {
        this.cartId = cartId;
        this.money = money;
    }
 
    public String getCartId() {
        return cartId;
    }
 
    public void setCartId(String cartId) {
        this.cartId = cartId;
    }
 
    public double getMoney() {
        return money;
    }
 
    public void setMoney(double money) {
        this.money = money;
    }
 
    public synchronized void savemoney(double money) {
        //先獲取是誰(shuí)來(lái)存錢(qián),線(xiàn)程名即是人名
        String name=Thread.currentThread().getName();
        //判斷賬戶(hù)是否有錢(qián)
        try {
            if(this.money==0){
                //沒(méi)錢(qián),存錢(qián)
                this.money+=money;
                System.out.println(name+"來(lái)存錢(qián),存了:"+money+"存錢(qián)后余額為:"+this.money);
                //有錢(qián)了
                //喚醒所有線(xiàn)程
                this.notifyAll();
                //鎖對(duì)象,讓當(dāng)前線(xiàn)程進(jìn)入等待
                this.wait();
            }else {
                //有錢(qián),不存錢(qián)
                //喚醒所有線(xiàn)程
                this.notifyAll();
                //鎖對(duì)象,讓當(dāng)前線(xiàn)程進(jìn)入等待
                this.wait();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    public synchronized void drawmoney3(double money) {
        //先獲取是誰(shuí)來(lái)取錢(qián),線(xiàn)程名即是人名
        String name=Thread.currentThread().getName();
        try {
            //判斷賬戶(hù)是否夠錢(qián)
            if(this.money>=money){
                //有錢(qián),取錢(qián)
                this.money-=money;
                System.out.println(name+"來(lái)取錢(qián)成功,取了:"+money+"余額是:"+this.money);
                //沒(méi)錢(qián)了
                //喚醒所有線(xiàn)程
                this.notifyAll();
                //鎖對(duì)象,讓當(dāng)前線(xiàn)程進(jìn)入等待
                this.wait();
            }else{
                //余額不足
                //喚醒所有線(xiàn)程
                this.notifyAll();
                //鎖對(duì)象,讓當(dāng)前線(xiàn)程進(jìn)入等待
                this.wait();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

以上就是Java實(shí)現(xiàn)線(xiàn)程通信的案例講解的詳細(xì)內(nèi)容,更多關(guān)于Java線(xiàn)程通信的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • intellij idea如何將web項(xiàng)目打成war包的實(shí)現(xiàn)

    intellij idea如何將web項(xiàng)目打成war包的實(shí)現(xiàn)

    這篇文章主要介紹了intellij idea如何將web項(xiàng)目打成war包的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2020-07-07
  • Springboot發(fā)送郵件功能的實(shí)現(xiàn)詳解

    Springboot發(fā)送郵件功能的實(shí)現(xiàn)詳解

    電子郵件是—種用電子手段提供信息交換的通信方式,是互聯(lián)網(wǎng)應(yīng)用最廣的服務(wù)。本文詳細(xì)為大家介紹了SpringBoot實(shí)現(xiàn)發(fā)送電子郵件功能的示例代碼,需要的可以參考一下
    2022-09-09
  • Elasticsearch中FST與前綴搜索應(yīng)用實(shí)戰(zhàn)解析

    Elasticsearch中FST與前綴搜索應(yīng)用實(shí)戰(zhàn)解析

    這篇文章主要為大家介紹了Elasticsearch中FST與前綴搜索應(yīng)用實(shí)戰(zhàn)解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-08-08
  • Java生成非對(duì)稱(chēng)型加密公鑰和私鑰的方法

    Java生成非對(duì)稱(chēng)型加密公鑰和私鑰的方法

    這篇文章主要介紹了Java生成非對(duì)稱(chēng)型加密公鑰和私鑰的方法,涉及java非對(duì)稱(chēng)加密的原理與實(shí)現(xiàn)技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下
    2015-07-07
  • IDEA新建springboot項(xiàng)目時(shí)未生成pom.xml文件的解決操作

    IDEA新建springboot項(xiàng)目時(shí)未生成pom.xml文件的解決操作

    這篇文章主要給大家介紹了關(guān)于IDEA新建springboot項(xiàng)目時(shí)未生成pom.xml文件的解決操作方法,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2023-02-02
  • springcloud?整合?openfeign的方法

    springcloud?整合?openfeign的方法

    openFeign 是springcloud對(duì)Feign進(jìn)行了增強(qiáng),使得Feign支持了springmvc的注解,并整合了Ribbon和Eureka,從而讓Feign的使用更加方便,這篇文章主要介紹了springcloud?整合?openfeign,需要的朋友可以參考下
    2022-09-09
  • 詳解spring cloud整合Swagger2構(gòu)建RESTful服務(wù)的APIs

    詳解spring cloud整合Swagger2構(gòu)建RESTful服務(wù)的APIs

    這篇文章主要介紹了詳解spring cloud整合Swagger2構(gòu)建RESTful服務(wù)的APIs,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2018-01-01
  • Java中的IO讀寫(xiě)原理詳解

    Java中的IO讀寫(xiě)原理詳解

    這篇文章主要介紹了Java中的IO讀寫(xiě)原理,IO是指輸入和輸出操作的技術(shù),它提供了一組用于讀取和寫(xiě)入數(shù)據(jù)的類(lèi),以及用于處理字符和字節(jié)數(shù)據(jù)的接口,這些類(lèi)和接口可以用于讀取和寫(xiě)入文件、網(wǎng)絡(luò)流、內(nèi)存緩沖區(qū)等各種數(shù)據(jù)源和目標(biāo),需要的朋友可以參考下
    2023-08-08
  • 詳解如何查看Elasticsearch的Debug日志

    詳解如何查看Elasticsearch的Debug日志

    這篇文章主要為大家介紹了詳解如何查看Elasticsearch的Debug日志,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-11-11
  • springboot中使用rabbitt的詳細(xì)方法

    springboot中使用rabbitt的詳細(xì)方法

    這篇文章主要介紹了springboot中使用rabbitt,通過(guò)本文學(xué)習(xí)讓我們了解如何在Spring Boot中使用RabbitMQ,并使用不同的交換機(jī)和隊(duì)列類(lèi)型以及消息確認(rèn)模式,需要的朋友可以參考下
    2023-05-05

最新評(píng)論