怎么使用Disruptor中的鎖和CAS

本篇內(nèi)容介紹了“怎么使用Disruptor中的鎖和CAS”的有關(guān)知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細閱讀，能夠?qū)W有所成！

關(guān)于鎖和CAS

保證線程安全一般分成兩種方式：鎖和原子變量。

例如，Thread1和Thread2都要把Entry加1。若不加鎖，也不使用CAS，有可能Thread1取到了myValue=1，Thread2也取到了myValue=1，然后相加，Entry中的value值為2。這與預(yù)期不相符，我們預(yù)期的是Entry的值經(jīng)過兩次相加后等于3。

鎖

采取加鎖的方式，默認(rèn)線程會沖突，訪問數(shù)據(jù)時，先加上鎖再訪問，訪問之后再解鎖。通過鎖界定一個臨界區(qū)，同時只有一個線程進入。Thread2訪問Entry的時候，加了鎖，Thread1就不能再執(zhí)行訪問Entry的代碼，從而保證線程安全。

下面是ArrayBlockingQueue通過加鎖的方式實現(xiàn)的offer方法，保證線程安全。

public boolean offer(E e) {
    checkNotNull(e);
    final ReentrantLock lock = this.lock;
    lock.lock();
    try {
        if (count == items.length)
            return false;
        else {
            insert(e);
            return true;
        }
    } finally {
        lock.unlock();
    }
}

原子變量

原子變量能夠保證原子性的操作，意思是某個任務(wù)在執(zhí)行過程中，要么全部成功，要么全部失敗回滾，恢復(fù)到執(zhí)行之前的初態(tài)，不存在初態(tài)和成功之間的中間狀態(tài)。例如CAS操作，要么比較并交換成功，要么比較并交換失敗。由CPU保證原子性。

通過原子變量可以實現(xiàn)線程安全。執(zhí)行某個任務(wù)的時候，先假定不會有沖突，若不發(fā)生沖突，則直接執(zhí)行成功；當(dāng)發(fā)生沖突的時候，則執(zhí)行失敗，回滾再重新操作，直到不發(fā)生沖突。

CAS會先把Entry現(xiàn)在的value跟線程當(dāng)初讀出的值相比較，若相同，則賦值；若不相同，則賦值執(zhí)行失敗。一般會通過while/for循環(huán)來重新執(zhí)行，直到賦值成功。

代碼示例是AtomicInteger的getAndAdd方法。CAS是CPU的一個指令，由CPU保證原子性。

/**
 * Atomically adds the given value to the current value.
 *
 * @param delta the value to add
 * @return the previous value
 */
public final int getAndAdd(int delta) {
    for (;;) {
        int current = get();
        int next = current + delta;
        if (compareAndSet(current, next))
            return current;
    }
}
  
/**
 * Atomically sets the value to the given updated value
 * if the current value {@code ==} the expected value.
 *
 * @param expect the expected value
 * @param update the new value
 * @return true if successful. False return indicates that
 * the actual value was not equal to the expected value.
 */
public final boolean compareAndSet(int expect, int update) {
    return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
}

“怎么使用Disruptor中的鎖和CAS”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！