共享变量实现线程间通信

小鱼儿 2024-03-17 09:11 62阅读 0赞

**wait();**方法的作用是当前线程进程读取关系，使多个线程对象协作完成某项工作。

注意：使用wait();方法会抛出InterruptedException异常，需要对其进行捕获，另外，wait();方法使线程为等待状态，而要使处于等待线程的状态的线程切换到就绪状态，必须使用notify();和notifyAll();方法。

**notify();/notifyAll();**方法的作用是唤醒一个或所有正在等待队列中处于等待状态的线程，并将他们移入等待同一个·。“对象互斥锁”的队列。

这三种方法都只能在被声明为synchronized的

方法或代码段中使用。

/\*\*

\*银行账号类

\*/

package Demo;
    
    public class MyBank {
        public double getBalance() {
            return balance;
        }
    
        public void setBalance(double balance) {
            this.balance = balance;
        }
    
        private double balance;//余额
    
        public String getAccount() {
            return account;
        }
    
        public void setAccount(String account) {
            this.account = account;
        }
    
        private String account;//账号
        private boolean haveMoney=false;//是否有钱的标准值，初始值为false
        public MyBank() {
        }
            public MyBank(String a,double b){
                this.account=a;
                this.balance=b;
            }
        public synchronized  void deposite(double dAccount)throws InterruptedException{
            if(haveMoney){
                wait();
            }else{
                this.setBalance(this.getBalance()+dAccount);
                System.out.println(Thread.currentThread().getName()+"存款"+dAccount+"元，当前余额为："+this.getBalance()+"元");
                haveMoney=true;
                notify();
            }
        }
        public synchronized void withdrawal(double dAmount)throws InterruptedException{
            if(!haveMoney){
                wait();
            }else{
                if(this.getBalance()>=dAmount){
                    System.out.println(Thread.currentThread().getName()+"取款成功，吐出钞票:"+dAmount+'元');
                    this.setBalance(this.getBalance()-dAmount);
                    System.out.println("当前余额为"+this.getBalance()+'元');
                    haveMoney=false;
                    notifyAll();
                }else{
                    System.out.println("余额不足");
                }
            }
        }
    }

/\*\*

\*取款线程类，在本线程中实现3次取款线程

\*/

package Demo;
    
    public class WithdrawalThread extends Thread{
        MyBank bank;
        double mount;
        public WithdrawalThread(String name,MyBank bank,double amount){
            super(name);
            this.bank=bank;
            this.mount=amount;
        }
        public void run(){
            for(int i=0;i<3;i++){
                try{
                    bank.withdrawal(mount);
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
            }
        }
    }

/\*\*

\*存款线程类，在本线程中实现3次存款操作

\*/

package Demo;
    
    public class DepositeThread extends Thread{
        MyBank bank;
        double mount;
        public DepositeThread(String name,MyBank bank,double dAmount){
            super(name);
            this.bank=bank;
            this.mount=dAmount;
        }
        public void run(){
            for(int i=0;i<3;i++){
                try{
                    bank.deposite(mount);
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
            }
        }
    }

/\*\*

\*主线程，通过使用中间共享变量，实款存储线程与取款线程之间的通信

\*/

package Demo;
    
    public class Test {
        public static void main(String[] args) {
    
            MyBank bank=new MyBank("0002",0);
    
            //实例化取钱线程和存钱线程
            WithdrawalThread wt=new WithdrawalThread("取款者",bank,2000);
            DepositeThread dt=new DepositeThread("存款者",bank,2000);
    
            //启动进程
            wt.start();
            dt.start();
    
            //System.out.println("Hello world!");
        }
    }