java并發(fā)編程學(xué)習(xí)之再談公平鎖和非公平鎖

warkiz 發(fā)布于2019-08-19 11:48 / 1344人閱讀

摘要：在并發(fā)編程學(xué)習(xí)之顯示鎖里有提過公平鎖和非公平鎖，我們知道他的使用方式，以及非公平鎖的性能較高，在源碼分析的基礎(chǔ)上，我們看看和的區(qū)別在什么地方。而非公平鎖直接嘗試獲取鎖。

在java并發(fā)編程學(xué)習(xí)之顯示鎖Lock里有提過公平鎖和非公平鎖，我們知道他的使用方式，以及非公平鎖的性能較高，在AQS源碼分析的基礎(chǔ)上，我們看看NonfairSync和FairSync的區(qū)別在什么地方。

lock方法

//非公平鎖NonfairSync
final void lock() {
    if (compareAndSetState(0, 1))
        setExclusiveOwnerThread(Thread.currentThread());
    else
        acquire(1);
}
//公平鎖FairSync
final void lock() {
    acquire(1);
}

從源碼可以看出，獲取鎖的時候，非公平鎖會先嘗試獲取，獲取不到再調(diào)用acquire方法，而公平鎖直接調(diào)用acquire方法。

tryAcquire方法

////非公平鎖NonfairSync
protected final boolean tryAcquire(int acquires) {
    return nonfairTryAcquire(acquires);
}
final boolean nonfairTryAcquire(int acquires) {
    final Thread current = Thread.currentThread();
    int c = getState();
    if (c == 0) {
        if (compareAndSetState(0, acquires)) {
            setExclusiveOwnerThread(current);
            return true;
        }
    }
    else if (current == getExclusiveOwnerThread()) {
        int nextc = c + acquires;
        if (nextc < 0) // overflow
            throw new Error("Maximum lock count exceeded");
        setState(nextc);
        return true;
    }
    return false;
}
////公平鎖FairSync
protected final boolean tryAcquire(int acquires) {
    final Thread current = Thread.currentThread();
    int c = getState();//無線程占用
    if (c == 0) {
        if (!hasQueuedPredecessors() &&//看是否有前面節(jié)點在等待
            compareAndSetState(0, acquires)) {
            setExclusiveOwnerThread(current);
            return true;
        }
    }
    else if (current == getExclusiveOwnerThread()) {
        int nextc = c + acquires;
        if (nextc < 0)
            throw new Error("Maximum lock count exceeded");
        setState(nextc);
        return true;
    }
    return false;
}

從源碼可以看出，公平鎖再嘗試獲取鎖的時候，先判斷隊列是否有其他節(jié)點在等待，沒有再獲取。而非公平鎖直接嘗試獲取鎖。