Java鎖對象和條件對象的使用

鎖對象

臨界區：臨界區是一個特殊的代碼段，該代碼段訪問某種特殊的公共資源，該資源同一時間只允許一個線程使用。

Java中可以使用鎖對象創造一個臨界區：

myLock.lock();
try {
    關鍵代碼
} finally {
    myLock.unlock();
}

 

使用這種結構可以確保關鍵代碼不會同時被多個線程執行，線程想要執行關鍵代碼必須先獲取“鎖”，“鎖”只能被一個線程持有，在該線程將“鎖”釋放前，其他線程因為獲取不到鎖而被阻塞，“鎖”被釋放的時候，之前因為獲取這個鎖被掛起的線程都會被喚醒，共同競爭着去獲取鎖。

將釋放鎖的操作寫在finally里是很重要的，防止某個線程執行關鍵代碼的時候因為拋出異常而沒有將鎖釋放。

 

 

package learnspringboot.xiao.learnjava.thread;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * @author xzy
 * @date 2019-12-13 11:01
 * 說明：模擬銀行轉賬
 */
public class Bank {
    private Map<String, Double> accountMap = new HashMap<>();
    private Lock myLock = new ReentrantLock();
    private Condition haveMoney = myLock.newCondition();

    public Bank() {
        this.accountMap.put("ZhangSan", 100.0);
        this.accountMap.put("WangWu", 1000.0);
    }

    public void transfer(String from, String to, Double money) {
        //線程執行后面的代碼段需要先獲得鎖，獲取不到就掛起。
        myLock.lock();
        System.out.println("當前獲得鎖的線程：" + Thread.currentThread().getName());
        System.out.println(from + "想給" + to + "轉" + money + "元," + from + "現在有" + accountMap.get(from) + "元");
        try {
            while (accountMap.get(from) < money) {
                System.out.println("線程阻塞：" + Thread.currentThread().getName());
                //獲取到鎖的線程需要等待本條件成立，條件成立前將鎖釋放，線程阻塞。
                haveMoney.await();
            }
            accountMap.put(from, accountMap.get(from) - money);
            accountMap.put(to, accountMap.get(to) + money);
            System.out.println(from + "轉給" + to + money + "元  線程：" + Thread.currentThread().getName());
            //通知因本條件而掛起的線程，條件現在可能已經滿足，可以試着再去獲取肯看。
            haveMoney.signalAll();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            myLock.unlock();
        }
    }

    public static void main(String[] args) {
        Bank bank = new Bank();
        Thread thread1 = new Thread(() -> {
            bank.transfer("ZhangSan", "WangWu", 500.0);
        });
        Thread thread2 = new Thread(() -> {
            bank.transfer("WangWu", "ZhangSan", 1000.0);
        });
        Thread thread3 = new Thread(() -> {
            bank.transfer("ZhangSan", "WangWu", 500.0);
        });
        thread1.setName("張三給王五500 x1");
        thread2.setName("王五給張三1000");
        thread3.setName("張三給王五500 x2");
        thread1.start();
        thread2.start();
        thread3.start();
        while (true) {

        }
    }
}