多线程同步机制练习之银行存钱

1 package day2_4; 2 3 import java.util.concurrent.locks.ReentrantLock; 4 5 /** 6 * 银行有一个账户。 7 * 两个储户向同一个账户里存钱，每个储户都是存3000元，分三次，每次存1000。 8 * 每次存完打印账户余额 9 * 10 * 分析： 11 * 1.是多线程问题吗？ 是，两个储户线程 12 * 2.是否有共享数据？ 有，同一个账户（或账户余额） 13 * 3.是否有线程安全问题？ 有 14 * 4.如何解决线程安全问题？ 同步机制：有三种方式 15 * 16 * 17 * @Author Tianhao 18 * @create 2021-02-05-18:21 19 */ 20 public class AccountTest { 21 public static void main(String[] args) { 22 Account acct = new Account(0); 23 Customer c1 = new Customer(acct); 24 Customer c2 = new Customer(acct); 25 c1.setName("客户1"); 26 c2.setName("客户2"); 27 c1.start(); 28 c2.start(); 29 } 30 31 } 32 33 //账号 34 class Account { 35 //余额 36 private double balance = 0; 37 38 public Account(double balance) { 39 this.balance = balance; 40 } 41 42 private ReentrantLock lock = new ReentrantLock(); 43 44 //存钱操作 45 //这里虽然线程类是继承Thread方式创建，但同步方法上没有static修饰 46 //因为这个方法所在Account类的对象acct是多个线程共享的，就可以用this作为同步监视器 47 //解决线程安全问题：方式一：使用同步方法 48 // public synchronized void deposit(double amt) { 49 // if (amt > 0) { 50 // balance += amt; 51 // try { 52 // Thread.sleep(1000); 53 // } catch (InterruptedException e) { 54 // e.printStackTrace(); 55 // } 56 // System.out.println( Thread.currentThread().getName() + ":存钱成功。余额：" + balance); 57 // } 58 // } 59 60 //解决线程安全问题：方式二：使用同步代码块 61 public void deposit(double amt) { 62 synchronized (this) { 63 if (amt > 0) { 64 balance += amt; 65 try { 66 Thread.sleep(1000); 67 } catch (InterruptedException e) { 68 e.printStackTrace(); 69 } 70 System.out.println(Thread.currentThread().getName() + ":存钱成功。余额：" + balance); 71 } 72 } 73 } 74 75 76 //解决线程安全问题：方式三：使用lock方法 77 // public synchronized void deposit(double amt) { 78 // try { 79 // lock.lock(); 80 // if (amt > 0) { 81 // balance += amt; 82 // try { 83 // Thread.sleep(1000); 84 // } catch (InterruptedException e) { 85 // e.printStackTrace(); 86 // } 87 // System.out.println( Thread.currentThread().getName() + ":存钱成功。余额：" + balance); 88 // } 89 // }finally { 90 // lock.unlock(); 91 // } 92 // } 93 94 public double getBalance() { 95 return balance; 96 } 97 } 98 //储户 99 class Customer extends Thread{ 100 private Account acct; 101 //将Account对象作为参数传入到构造器，这样就保证了创建的 102 // 每个Customer对象都是同一个Account对象 103 public Customer(Account acct) { 104 this.acct = acct; 105 } 106 107 @Override 108 public void run() { 109 for (int i = 0; i < 3; i++) { 110 acct.deposit(1000); 111 } 112 } 113 }