Maison > Java > javaDidacticiel > Comment implémenter la communication inter-thread en Java ?

Comment implémenter la communication inter-thread en Java ?

WBOY
Libérer: 2023-04-20 20:46:09
avant
797 Les gens l'ont consulté

Qu'est-ce que la communication par thread et comment la mettre en œuvre ?

La communication dite par thread consiste à s'envoyer des données entre les threads. La communication par thread est généralement réalisée en partageant des données.

Les discussions décideront quoi faire en fonction des données partagées et informeront les autres discussions de ce qu'elles doivent faire.

Modèles courants de communication par thread

Modèles producteur et consommateur : les threads producteurs sont responsables de la production de données et les threads consommateurs sont responsables de la consommation des données.

Exigence : Une fois que le thread producteur a fini de produire les données, réveillez le consommateur puis attendez lui-même ; une fois que le consommateur a fini de consommer les données, réveillez le producteur puis attendez lui-même

public class 多线程_5线程通信 extends Thread{
 
    public static void main(String[] args) {
        //定义线程类,创建一个共享的账户对象
        account3 a=new account3("abc",0);
        //创建两个取钱的线程对象
        new drawthread3(a,"小明").start();
        new drawthread3(a,"小红").start();
        //创建三个存钱的线程对象
        new savethread(a,"存钱罐1号").start();
        new savethread(a,"存钱罐2号").start();
        new savethread(a,"存钱罐3号").start();
    }
}
//存钱的线程类
class savethread extends Thread{
    //接收处理的账户对象
    private account3 acc;
    public savethread(account3 acc,String name){
        super(name);
        this.acc=acc;
    }
    public void run(){
        try {
            while (true){
                //存钱
                acc.savemoney(100000);
                //休眠2秒
                Thread.sleep(2000);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
//取钱的线程类
class drawthread3 extends Thread{
    //接收处理的账户对象
    private account3 acc;
    public drawthread3(account3 acc,String name){
        super(name);
        this.acc=acc;
    }
    public void run(){
        try {
            while (true){
                //取钱
                acc.drawmoney3(100000);
                //休眠2秒
                Thread.sleep(2000);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
class account3{
    private String cartId;
    private double money;//账户余额
 
    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) {
        //先获取是谁来存钱,线程名即是人名
        String name=Thread.currentThread().getName();
        //判断账户是否有钱
        try {
            if(this.money==0){
                //没钱,存钱
                this.money+=money;
                System.out.println(name+"来存钱,存了:"+money+"存钱后余额为:"+this.money);
                //有钱了
                //唤醒所有线程
                this.notifyAll();
                //锁对象,让当前线程进入等待
                this.wait();
            }else {
                //有钱,不存钱
                //唤醒所有线程
                this.notifyAll();
                //锁对象,让当前线程进入等待
                this.wait();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    public synchronized void drawmoney3(double money) {
        //先获取是谁来取钱,线程名即是人名
        String name=Thread.currentThread().getName();
        try {
            //判断账户是否够钱
            if(this.money>=money){
                //有钱,取钱
                this.money-=money;
                System.out.println(name+"来取钱成功,取了:"+money+"余额是:"+this.money);
                //没钱了
                //唤醒所有线程
                this.notifyAll();
                //锁对象,让当前线程进入等待
                this.wait();
            }else{
                //余额不足
                //唤醒所有线程
                this.notifyAll();
                //锁对象,让当前线程进入等待
                this.wait();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
Copier après la connexion

Comment implémenter la communication inter-thread en Java ?

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Étiquettes associées:
source:yisu.com
Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Tutoriels populaires
Plus>
Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal