快捷導(dǎo)航

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

更新時(shí)間：2022年05月26日 14:17:08 作者：遇安.112

所謂線程通信就是線程間相互發(fā)送數(shù)據(jù)，線程通信通常通過(guò)共享一個(gè)數(shù)據(jù)的方式實(shí)現(xiàn)。本文將通過(guò)案例詳解Java中線程通信的實(shí)現(xiàn)，感興趣的可以了解一下

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

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

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

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

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

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

public class 多線程_5線程通信 extends Thread{
 
    public static void main(String[] args) {
        //定義線程類(lèi)，創(chuàng)建一個(gè)共享的賬戶(hù)對(duì)象
        account3 a=new account3("abc",0);
        //創(chuàng)建兩個(gè)取錢(qián)的線程對(duì)象
        new drawthread3(a,"小明").start();
        new drawthread3(a,"小紅").start();
        //創(chuàng)建三個(gè)存錢(qiá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)的線程類(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)的線程類(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)，線程名即是人名
        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)了
                //喚醒所有線程
                this.notifyAll();
                //鎖對(duì)象，讓當(dāng)前線程進(jìn)入等待
                this.wait();
            }else {
                //有錢(qián),不存錢(qián)
                //喚醒所有線程
                this.notifyAll();
                //鎖對(duì)象，讓當(dāng)前線程進(jìn)入等待
                this.wait();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    public synchronized void drawmoney3(double money) {
        //先獲取是誰(shuí)來(lái)取錢(qiá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)了
                //喚醒所有線程
                this.notifyAll();
                //鎖對(duì)象，讓當(dāng)前線程進(jìn)入等待
                this.wait();
            }else{
                //余額不足
                //喚醒所有線程
                this.notifyAll();
                //鎖對(duì)象，讓當(dāng)前線程進(jìn)入等待
                this.wait();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}