Java에서 스레드 간 통신을 구현하는 방법은 무엇입니까?

스레드 통신이란 무엇이며 어떻게 구현하나요?

스레드 통신이란 스레드 간에 데이터를 서로 보내는 것을 말합니다. 스레드 통신은 일반적으로 데이터를 공유함으로써 이루어집니다.

스레드는 공유된 데이터를 기반으로 무엇을 할지 결정하고, 다른 스레드에게 무엇을 할지 알려줍니다.

스레드 통신의 일반적인 모델

생산자 및 소비자 모델: 생산자 스레드는 데이터 생성을 담당하고 소비자 스레드는 데이터 소비를 담당합니다.

요구 사항: 생산자 스레드가 데이터 생성을 마친 후 소비자를 깨운 다음 ​​스스로 기다립니다. 소비자가 데이터 소비를 마친 후 생산자를 깨운 다음 ​​자체를 기다립니다.

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();
        }
    }
}

위 내용은 Java에서 스레드 간 통신을 구현하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!