public class ThreadTest {

 public static void main(String[] args) {
  Account account = new Account("123456", 1000);
  DrawMoneyRunnable drawMoneyRunnable = new DrawMoneyRunnable(account, 700);
  Thread myThread1 = new Thread(drawMoneyRunnable);
  Thread myThread2 = new Thread(drawMoneyRunnable);
  myThread1.start();
  myThread2.start();
 }

}

class DrawMoneyRunnable implements Runnable {

 private Account account;
 private double drawAmount;

 public DrawMoneyRunnable(Account account, double drawAmount) {
  super();
  this.account = account;
  this.drawAmount = drawAmount;
 }

 public void run() {
  if (account.getBalance() >= drawAmount) { //1
   System.out.println("取錢成功， 取出錢數(shù)為：" + drawAmount);
   double balance = account.getBalance() - drawAmount;
   account.setBalance(balance);
   System.out.println("余額為：" + balance);
  }
 }
}

class Account {

 private String accountNo;
 private double balance;

 public Account() {

 }

 public Account(String accountNo, double balance) {
  this.accountNo = accountNo;
  this.balance = balance;
 }

 public String getAccountNo() {
  return accountNo;
 }

 public void setAccountNo(String accountNo) {
  this.accountNo = accountNo;
 }

 public double getBalance() {
  return balance;
 }

 public void setBalance(double balance) {
  this.balance = balance;
 }

}

 public synchronized void run() {
  
 // ....
 
}

 synchronized (obj) {
    
  //...
 
 }

class X {
 
 // 顯示定義Lock同步鎖對象，此對象與共享資源具有一對一關(guān)系
 private final Lock lock = new ReentrantLock();
 
 public void m(){
  // 加鎖
  lock.lock();
  
  //... 需要進(jìn)行線程安全同步的代碼
  
  // 釋放Lock鎖
  lock.unlock();
 }
 
}

package com.qqyumidi;

public class ThreadTest {

 public static void main(String[] args) {
  Account account = new Account("123456", 0);

  Thread drawMoneyThread = new DrawMoneyThread("取錢線程", account, 700);
  Thread depositeMoneyThread = new DepositeMoneyThread("存錢線程", account, 700);

  drawMoneyThread.start();
  depositeMoneyThread.start();
 }

}

class DrawMoneyThread extends Thread {

 private Account account;
 private double amount;

 public DrawMoneyThread(String threadName, Account account, double amount) {
  super(threadName);
  this.account = account;
  this.amount = amount;
 }

 public void run() {
  for (int i = 0; i < 100; i++) {
   account.draw(amount, i);
  }
 }
}

class DepositeMoneyThread extends Thread {

 private Account account;
 private double amount;

 public DepositeMoneyThread(String threadName, Account account, double amount) {
  super(threadName);
  this.account = account;
  this.amount = amount;
 }

 public void run() {
  for (int i = 0; i < 100; i++) {
   account.deposite(amount, i);
  }
 }
}

class Account {

 private String accountNo;
 private double balance;
 // 標(biāo)識賬戶中是否已有存款
 private boolean flag = false;

 public Account() {

 }

 public Account(String accountNo, double balance) {
  this.accountNo = accountNo;
  this.balance = balance;
 }

 public String getAccountNo() {
  return accountNo;
 }

 public void setAccountNo(String accountNo) {
  this.accountNo = accountNo;
 }

 public double getBalance() {
  return balance;
 }

 public void setBalance(double balance) {
  this.balance = balance;
 }

 /**
  * 存錢
  * 
  * @param depositeAmount
  */
 public synchronized void deposite(double depositeAmount, int i) {

  if (flag) {
   // 賬戶中已有人存錢進(jìn)去，此時(shí)當(dāng)前線程需要等待阻塞
   try {
    System.out.println(Thread.currentThread().getName() + " 開始要執(zhí)行wait操作" + " -- i=" + i);
    wait();
    // 1
    System.out.println(Thread.currentThread().getName() + " 執(zhí)行了wait操作" + " -- i=" + i);
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  } else {
   // 開始存錢
   System.out.println(Thread.currentThread().getName() + " 存款:" + depositeAmount + " -- i=" + i);
   setBalance(balance + depositeAmount);
   flag = true;

   // 喚醒其他線程
   notifyAll();

   // 2
   try {
    Thread.sleep(3000);
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
   System.out.println(Thread.currentThread().getName() + "-- 存錢 -- 執(zhí)行完畢" + " -- i=" + i);
  }
 }

 /**
  * 取錢
  * 
  * @param drawAmount
  */
 public synchronized void draw(double drawAmount, int i) {
  if (!flag) {
   // 賬戶中還沒人存錢進(jìn)去，此時(shí)當(dāng)前線程需要等待阻塞
   try {
    System.out.println(Thread.currentThread().getName() + " 開始要執(zhí)行wait操作" + " 執(zhí)行了wait操作" + " -- i=" + i);
    wait();
    System.out.println(Thread.currentThread().getName() + " 執(zhí)行了wait操作" + " 執(zhí)行了wait操作" + " -- i=" + i);
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  } else {
   // 開始取錢
   System.out.println(Thread.currentThread().getName() + " 取錢：" + drawAmount + " -- i=" + i);
   setBalance(getBalance() - drawAmount);

   flag = false;

   // 喚醒其他線程
   notifyAll();

   System.out.println(Thread.currentThread().getName() + "-- 取錢 -- 執(zhí)行完畢" + " -- i=" + i); // 3
  }
 }

}