本文深入探讨了在java多线程环境中，如何有效实现共享银行账户的并发存取。通过一个模拟两人操作同一账户的场景，我们将详细介绍如何利用`synchronized`关键字以及`wait()`和`notifyall()`方法，在账户类中正确管理线程间的协作与资源同步，确保账户余额的线程安全，并避免常见的并发问题，从而构建一个健壮、高效的并发应用。
在多线程编程中，当多个线程共享同一个资源时，必须采取适当的同步机制来防止数据不一致和竞态条件。银行账户的存取操作是一个典型的共享资源问题，需要确保在并发环境下，账户余额能够被正确地更新，并且满足特定的业务规则（如最大存款额、最小取款额）。Java提供了synchronized关键字以及Object类的wait()、notify()和notifyAll()方法来实现线程间的同步与协作。
1. 核心概念回顾
在深入实现之前，我们先回顾几个关键的Java并发概念：
synchronized关键字：用于修饰方法或代码块，确保在任何时刻只有一个线程可以执行被synchronized保护的代码。它提供了互斥锁，防止多个线程同时修改共享数据。wait()方法：当一个线程在synchronized代码块中遇到某个条件不满足时（例如，账户余额不足或已达上限），可以调用wait()方法。调用wait()会使当前线程释放它所持有的锁，并进入等待状态，直到被其他线程唤醒。notify()和notifyAll()方法：用于唤醒在同一对象上调用了wait()方法的线程。notify()随机唤醒一个等待线程，而notifyAll()则唤醒所有等待线程。被唤醒的线程会尝试重新获取锁，并在获取到锁后从wait()的地方继续执行。
wait()、notify()和notifyAll()方法必须在synchronized方法或synchronized块中调用，并且它们作用的对象必须是当前线程所持有的锁对象。
2. 共享账户同步问题分析
假设我们有一个银行账户，由两个人（两个线程）共享。他们需要并发地进行存款（ingreso）和取款（retiro）操作。账户有最大存款限制（500欧元）和最小余额限制（1欧元）。当存款操作导致余额超出上限时，或者取款操作导致余额低于下限时，当前线程应等待，直到条件允许。当其他线程改变了账户状态后，应唤醒等待的线程。
立即学习“Java免费学习笔记（深入）”；
初始的尝试可能将wait()和notifyAll()放在线程类（Persona）中，试图让线程自身等待和唤醒。然而，这种做法是错误的。wait()和notifyAll()必须作用于共享资源的锁对象上，即本例中的Cuenta（账户）实例。如果将它们放在Persona类中，每个Persona实例都有自己的锁对象，线程之间无法通过同一个锁对象进行有效的通信和协调。正确的做法是，将这些同步和通信逻辑封装在共享资源（Cuenta）的方法中。
3. 解决方案设计与实现
我们将设计三个类来模拟这个场景：BPA（主应用类）、Persona（人物/线程类）和Cuenta（账户类）。
3.1 Cuenta类：共享账户
Cuenta类是共享资源，它的ingreso（存款）和retiro（取款）方法必须是synchronized的，以确保每次只有一个线程能够修改账户余额。同时，这些方法内部将包含条件判断和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 执行操作的人名 * @param cuenta 账户实例 (虽然参数中包含，但实际操作的是当前对象) */ public synchronized void retiro(String nombre, Cuenta cuenta) { int dinero; Random rnd = new Random(); // 随机生成取款金额，范围在0到349之间 dinero = (int) (rnd.nextDouble() * 350.0); // 检查取款后是否会低于最小余额 while ((saldo - dinero) saldoMax) { System.out.println(" **** 账户已满！" + nombre + " 尝试存入: " + dinero + " 欧元. 当前余额: " + getSaldo() + " 欧元. ****"); System.out.println(" ---- " + nombre + " 正在等待取款，以便能存入更多钱 ---- "); try { // 余额已满，当前线程等待，并释放Cuenta对象的锁 wait(); } catch (InterruptedException e) { System.out.println("存款等待被中断"); Thread.currentThread().interrupt(); // 重新设置中断标志 } // 唤醒后，重新检查条件，防止虚假唤醒 dinero = (int) (rnd.nextDouble() * 350.0); // 重新生成存款金额 } // 条件满足，执行存款 this.saldo = this.saldo + dinero; System.out.println("Name: " + nombre + " 存入: " + dinero + " 欧元. 总余额: " + getSaldo() + " 欧元."); // 唤醒所有在Cuenta对象上等待的线程 notifyAll(); } public int getSaldo() { return saldo; }}
关键点说明：
九歌
九歌–人工智能诗歌写作系统
322 查看详情 
ingreso和retiro方法都是synchronized的，确保了对saldo的原子操作。while循环用于检查条件（saldo – dinero saldoMax）。使用while而不是if是为了处理“虚假唤醒”（Spurious Wakeup）问题，即线程可能在没有被notify()或notifyAll()唤醒的情况下意外地从wait()返回。每次唤醒后，线程都会重新检查条件。wait()：当条件不满足时，调用此方法使当前线程进入等待状态并释放Cuenta对象的锁。notifyAll()：每次成功存取后，调用此方法唤醒所有在Cuenta对象上等待的线程，让他们有机会重新检查条件并执行操作。
3.2 Persona类：操作账户的线程
Persona类继承自Thread，代表一个操作账户的个体。每个Persona实例都会持有同一个Cuenta对象的引用。
package BPA;import java.util.logging.Level;import java.util.logging.Logger;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); cuenta.retiro(nombre, cuenta); try { // 为了模拟真实场景和避免CPU空转，线程可以短暂休眠 Thread.sleep(500); // 每次操作后休眠500毫秒 } catch (InterruptedException e) { System.out.println(nombre + " 的操作被中断."); Thread.currentThread().interrupt(); // 重新设置中断标志 break; // 线程中断时退出循环 } } }}
关键点说明：
Persona线程的run()方法中包含一个无限循环，不断尝试进行存款和取款。Thread.sleep()是为了模拟操作之间的时间间隔，防止线程过于频繁地尝试获取锁，从而提高可读性和观察性。run()方法本身不需要synchronized，因为对共享资源的同步已由Cuenta类的方法处理。
3.3 BPA类：主应用
BPA类是应用程序的入口点，负责创建账户实例和Persona线程，并启动它们。
package BPA;import java.util.logging.Level;import java.util.logging.Logger;public class BPA { public static void main(String[] args) { // 创建一个共享账户实例，初始余额40欧元，最大余额500欧元 Cuenta laCuenta = new Cuenta(40, 500); // 创建两个Persona线程，共享同一个Cuenta实例 Persona Ramon = new Persona("Ramon", laCuenta); Persona Quique = new Persona("Quique", laCuenta); // 启动线程 Quique.start(); Ramon.start(); try { // 主线程等待两个Persona线程执行完毕 // 在此示例中，Persona线程是无限循环，所以join()会一直等待 // 如果希望程序在特定条件或时间后停止，需要额外的中断逻辑 Quique.join(); Ramon.join(); } catch (InterruptedException ex) { System.out.println("主线程等待被中断"); Thread.currentThread().interrupt(); } }}
关键点说明：
main方法中创建了一个Cuenta对象，并将其传递给两个Persona线程，确保它们操作的是同一个共享账户。start()方法启动线程，使其执行run()方法。join()方法使主线程等待子线程执行完毕。在这个无限循环的例子中，join()会一直等待，直到线程被外部中断。
4. 运行效果与注意事项
运行此程序，您将看到Ramon和Quique两个线程交替地进行存款和取款操作。当账户余额不足以取款或达到存款上限时，相应的线程将进入等待状态，直到另一个线程通过存取操作改变了账户状态并调用notifyAll()将其唤醒。
重要注意事项：
wait()和notifyAll()的调用对象：它们必须在锁对象上调用。在本例中，ingreso和retiro方法是synchronized的，它们锁定了this（即Cuenta实例本身）。因此，wait()和notifyAll()也必须在Cuenta实例上调用。while循环检查条件：务必使用while循环而不是if语句来检查wait()唤醒后的条件。这是为了避免“虚假唤醒”以及确保在多线程竞争中，条件在线程真正执行前仍然满足。中断处理：在wait()和sleep()方法中，InterruptedException是必须处理的。通常，捕获到此异常后，应重新设置线程的中断状态 (Thread.currentThread().interrupt();)，并根据业务逻辑决定是继续执行还是退出。notify() vs notifyAll()：在本场景中，notifyAll()是更安全的选项。因为可能有多种原因导致线程等待（余额不足或余额已满），notifyAll()可以唤醒所有等待的线程，让他们重新评估条件，避免死锁。如果只用notify()，可能会唤醒一个无法继续执行的线程，导致其他能执行的线程继续等待。线程生命周期：本示例中的Persona线程是无限循环的。在实际应用中，您可能需要设计一个机制来优雅地停止这些线程，例如通过设置一个共享的volatile标志位并在run()循环中检查它。
5. 总结
通过上述实现，我们成功地解决了Java多线程环境下共享银行账户的并发存取问题。核心在于理解synchronized关键字提供的互斥访问，以及wait()和notifyAll()方法实现的线程间协作。正确地将这些机制应用于共享资源（Cuenta对象）的方法中，并遵循while循环检查条件、处理中断等最佳实践，是构建健壮并发应用的关键。这个模式不仅适用于银行账户，也适用于任何需要生产者-消费者或有限缓冲区的并发场景。
以上就是Java多线程银行账户同步：利用wait/notifyAll机制实现安全存取的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1076209.html
微信扫一扫 
支付宝扫一扫 
