package com.lxk.threadTest.bank;
/** 
 * 銀行model，一個(gè)總金額屬性。 
 * <p> 
 * 
 * @author lxk on 2017/6/26 
 */
public class Bank {
	/** 
   * 給銀行個(gè)啟動(dòng)資金，不然怎么干生意呢。 
   */
	private int sum = 200;
	//這個(gè)從來(lái)不這么用，但也算是正確的一種加鎖的機(jī)制：同步代碼塊。 
	//Object obj = new Object(); 
	/** 
   * 存錢(qián) 
   * 要是不加[synchronized--同步函數(shù)],則會(huì)出現(xiàn)多線程安全問(wèn)題。 
   */
	public synchronized void add(int n) {
		//synchronized (obj) { 
		sum = sum + n;
		try {
			Thread.sleep(10);
		}
		catch (Exception ignore) {
		}
		//當(dāng)存錢(qián)次數(shù)變多的時(shí)候，就可以發(fā)現(xiàn)，存錢(qián)的線程確實(shí)是2個(gè)在交替執(zhí)行存錢(qián)這個(gè)動(dòng)作的。 
		System.out.println(Thread.currentThread().getName() + "...sum=" + sum);
		//}
	}
	/** 
   * 取錢(qián) 
   * 要是不加[synchronized--同步函數(shù)],則會(huì)出現(xiàn)多線程安全問(wèn)題。 
   */
	public synchronized void reduce(int n) {
		if (sum - n >= 0) {
			sum = sum - n;
		} else {
			System.out.println("bank's money is not enough !");
		}
		try {
			Thread.sleep(30);
		}
		catch (Exception ignore) {
		}
		//當(dāng)存錢(qián)次數(shù)變多的時(shí)候，就可以發(fā)現(xiàn)，存錢(qián)的線程確實(shí)是2個(gè)在交替執(zhí)行存錢(qián)這個(gè)動(dòng)作的。 
		System.out.println(Thread.currentThread().getName() + "...sum=" + sum);
	}
}

package com.lxk.threadTest.bank;
/** 
 * 顧客，實(shí)現(xiàn)runnable()接口，多個(gè)人可以一起存錢(qián) 
 * 
 * @author lxk on 2017/6/26 
 */
public class Customer implements Runnable {
	/** 
   * 存錢(qián)類型 
   */
	static final String TYPE_ADD = "add";
	/** 
   * 取錢(qián)類型 
   */
	static final String TYPE_REDUCE = "reduce";
	/** 
   * 銀行 
   */
	private Bank bank;
	/** 
   * 對(duì)錢(qián)的操作類型，存錢(qián)or取錢(qián) 
   */
	private String type;
	/** 
   * 操作的次數(shù)，理論上是個(gè)正數(shù) 
   */
	private int time;
	/** 
   * 要存或者取多少錢(qián) 
   */
	private int money;
	public Customer() {
	}
	public Customer(Bank bank, String type, int time, int money) {
		this.bank = bank;
		this.type = type;
		this.time = time;
		this.money = money;
	}
	@Override 
	  public void run() {
		for (int x = 0; x < time; x++) {
			if (TYPE_ADD.equals(type)) {
				bank.add(money);
			} else if (TYPE_REDUCE.equals(type)) {
				bank.reduce(money);
			}
		}
	}
}

package com.lxk.threadTest.bank;
/** 
 * 銀行存錢(qián)的多線程實(shí)例 
 * <p> 
 * 【需求：】 
 * 銀行有一個(gè)金庫(kù)。 
 * 有兩個(gè)儲(chǔ)戶分別存或者取n * 100。 
 * 目的：該程序是否有安全問(wèn)題，如果有，如何解決？ 
 * <p> 
 * 【如何找問(wèn)題：】 
 * 1，明確哪些代碼是多線程運(yùn)行代碼。 
 * 2，明確共享數(shù)據(jù)。 
 * 3，明確多線程運(yùn)行代碼中哪些語(yǔ)句是操作共享數(shù)據(jù)的。 
 * 
 * @author lxk on 2017/6/26 
 */
public class Main {
	public static void main(String[] args) {
		//一個(gè)銀行and多個(gè)客戶 
		Bank bank = new Bank();
		int time = 10000;
		int money = 100;
		//這個(gè)客戶存錢(qián) 
		Customer c1 = new Customer(bank, Customer.TYPE_ADD, time, money);
		//這個(gè)客戶取錢(qián) 
		Customer c2 = new Customer(bank, Customer.TYPE_REDUCE, time, money);
		Thread t1 = new Thread(c1);
		Thread t2 = new Thread(c2);
		t1.start();
		t2.start();
	}
}