Java多线程账户同步：使用wait()和notifyAll()管理共享资源

package BPA;

import java.util.Random;

public class Cuenta {

    private int saldo; // 当前余额
    private final int saldoMax; // 最大余额
    private final int saldoMin = 1; // 最小余额

    public Cuenta(int saldoInicial, int saldoMaximo) {
        this.saldo = saldoInicial;
        this.saldoMax = saldoMaximo;
    }

    /**
     * 取款操作
     * @param nombre 操作人名称
     */
    public synchronized void retiro(String nombre) {
        int dinero = new Random().nextInt(350) + 1; // 随机生成取款金额 (1-350)

        // 使用while循环判断条件，防止虚假唤醒和条件再次不满足
        while ((saldo - dinero) < saldoMin) {
            System.out.println("  ****  账户余额不足！" + nombre + " 尝试取出: " + dinero + " 现有余额: " + getSaldo() + " ****");
            System.out.println(" ---- " + nombre + " 正在等待存款以进行取款 ---- ");
            try {
                wait(); // 余额不足，线程等待，并释放Cuenta对象的锁
            } catch (InterruptedException e) {
                System.out.println(nombre + " 的取款等待被中断。");
                Thread.currentThread().interrupt(); // 重新设置中断标志
                return; // 退出方法
            }
        }
        // 条件满足，执行取款
        this.saldo -= dinero;
        System.out.println("Name: " + nombre + " extract cash: " + dinero + " TOTAL CASH: " + getSaldo());
        notifyAll(); // 唤醒所有等待在Cuenta对象上的线程，包括可能等待存款的线程
    }

    /**
     * 存款操作
     * @param nombre 操作人名称
     */
    public synchronized void ingreso(String nombre) {
        int dinero = new Random().nextInt(350) + 1; // 随机生成存款金额 (1-350)

        // 使用while循环判断条件
        while ((saldo + dinero) > saldoMax) {
            System.out.println(" **** 账户已达上限！" + nombre + " 尝试存入: " + dinero + " 现有余额: " + getSaldo() + " ****");
            System.out.println(" ---- " + nombre + " 正在等待取款以进行存款 ---- ");
            try {
                wait(); // 余额超上限，线程等待，并释放Cuenta对象的锁
            } catch (InterruptedException e) {
                System.out.println(nombre + " 的存款等待被中断。");
                Thread.currentThread().interrupt(); // 重新设置中断标志
                return; // 退出方法
            }
        }
        // 条件满足，执行存款
        this.saldo += dinero;
        System.out.println("Name: " + nombre + " deposit cash: " + dinero + " TOTAL CASH: " + getSaldo());
        notifyAll(); // 唤醒所有等待在Cuenta对象上的线程，包括可能等待取款的线程
    }

    public int getSaldo() {
        return saldo;
    }
}

package BPA;

import java.util.Random;

public class Persona extends Thread {

    String nombre;
    private Cuenta cuenta;

    public Persona(String nombre, Cuenta cuenta) {
        this.nombre = nombre;
        this.cuenta = cuenta;
    }

    @Override
    public void run() {
        while (true) {
            // 线程循环进行存取款操作
            cuenta.ingreso(nombre);
            cuenta.retiro(nombre);

            try {
                // 模拟操作间隔，避免CPU空转过快，同时给其他线程机会
                Thread.sleep(new Random().nextInt(500) + 500); // 随机暂停0.5到1.0秒
            } catch (InterruptedException e) {
                System.out.println(nombre + " 的操作被中断。");
                Thread.currentThread().interrupt(); // 重新设置中断标志
                break; // 退出循环
            }
        }
    }
}

package BPA;

public class BPA {
    public static void main(String[] args) {
        // 创建一个初始余额为40，最大余额为500的账户
        Cuenta laCuenta = new Cuenta(40, 500);

        // 创建两个操作人线程，并关联到同一个账户
        Persona Ramon = new Persona("Ramon", laCuenta);
        Persona Quique = new Persona("Quique", laCuenta);

        // 启动线程
        Quique.start();
        Ramon.start();

        try {
            // 等待两个线程执行完毕（尽管在本例中它们会无限循环，除非被中断）
            Quique.join();
            Ramon.join();
        } catch (InterruptedException ex) {
            System.out.println("主线程被中断。");
        }
    }
}