這篇文章主要介紹了Java語言中cas指令的無鎖定程式實作實例,具有一定參考價值,需要的朋友可以了解下。
最開始接觸到相關的內容應該是從volatile關鍵字開始的吧,知道它可以保證變數的可見性,而且利用它可以實現讀與寫的原子操作。 。 。但是要實現一些複合的操作volatile就無能為力了。 。 。最典型的代表是遞增和遞減的操作。 。 。 。
我們知道,在並發的環境下,要實現資料的一致性,最簡單的方式就是加鎖,保證在同一時刻只有一個執行緒可以對資料進行操作。 。 。 。例如一個計數器,我們可以用如下的方式來實現:
public class Counter { private volatile int a = 0; public synchronized int incrAndGet(int number) { this.a += number; return a; } public synchronized int get() { return a; } }
我們對操作都用synchronized關鍵字進行修飾,並保證對屬性a的同步存取。 。 。這樣子確實可以保證在並發環境下a的一致性,但是由於使用了鎖,鎖的開銷,線程的調度等等會使得程式的伸縮性受到了限制,於是就有了很多無鎖的實現方式。 。 。 。
其實這些無鎖的方法都利用了處理器所提供的一些CAS(compare and switch)指令,這個CAS到底乾了啥事情呢,可以用下面這個方法來說明CAS所代表的語意:
public synchronized int compareAndSwap(int expect, int newValue) { int old = this.a; if (old == expect) { this.a = newValue; } return old; }
好吧,透過程式碼應該對CAS語意的標書很清楚了吧,好像現在大多數的處理器都實作了原子的CAS指令了吧。 。
好啦,那麼接下來來看看在java中CAS都用在了什麼地方了吧,首先來看AtomicInteger類型吧,這個是並發庫裡面提供的一個類型:
private volatile int value;
這個是內部定義的屬性吧,用來保存值,由於是volatile類型的,所以可以保證執行緒之間的可見性以及讀寫的原子性。 。 。
那麼接下來來看看幾個比較常用的方法:
public final int addAndGet(int delta) { for (;;) { int current = get(); int next = current + delta; if (compareAndSet(current, next)) return next; } }
這個方法的作用是在目前值的基礎上加上delta,這裡可以看到整個方法中並沒有加鎖,這程式碼其實就算是java中實作無鎖定計數器的方法,這裡compareAndSet方法的定義如下:
public final boolean compareAndSet(int expect, int update) { return unsafe.compareAndSwapInt(this, valueOffset, expect, update); }
由於呼叫了unsafe的方法,所以這個就無能為力了,其實應該可以猜到JVM呼叫了處理器本身的CAS指令來實現原子的操作。 。 。
基本上AtomicInteger類型的重要方法都是採用無鎖的方式實現的。 。因此在並發環境下,用這種類型能有更好的性能。 。 。
上面算是搞定了在java中實現無鎖的計數器,接下來來看看如何實現無鎖棧,直接貼代碼了,代碼是從《JAVA並發編程實戰》中模仿下來的:
package concurrenttest; import java.util.concurrent.atomic.AtomicReference; public class ConcurrentStack<e> { AtomicReference<node<e>> top = new AtomicReference<node<e>>(); public void push(E item) { Node<e> newHead = new Node<e>(item); Node<e> oldHead; while (true) { oldHead = top.get(); newHead.next = oldHead; if (top.compareAndSet(oldHead, newHead)) { return; } } } public E pop() { while (true) { Node<e> oldHead = top.get(); if (oldHead == null) { return null; } Node<e> newHead = oldHead.next; if (top.compareAndSet(oldHead, newHead)) { return oldHead.item; } } } private static class Node<e> { public final E item; public Node<e> next; public Node(E item) { this.item = item; } } }
好啦,上面的程式碼就算是實作了一個無鎖的棧,簡單吧。 。 。在並發環境中,無鎖定的資料結構伸縮性能夠比用鎖好得多。 。 。
在提到無鎖定程式設計的時候,就不得不提到無鎖定佇列,其實在concurrent函式庫中已經提供了無鎖定佇列的實作:ConcurrentLinkedQueue,我們來看看它的重要的方法實作吧:
public boolean offer(E e) { checkNotNull(e); final Node<e> newNode = new Node<e>(e); for (Node<e> t = tail, p = t;;) { Node<e> q = p.next; if (q == null) { // p is last node if (p.casNext(null, newNode)) { // Successful CAS is the linearization point // for e to become an element of this queue, // and for newNode to become "live". if (p != t) // hop two nodes at a time casTail(t, newNode); // Failure is OK. return true; } // Lost CAS race to another thread; re-read next } else if (p == q) // We have fallen off list. If tail is unchanged, it // will also be off-list, in which case we need to // jump to head, from which all live nodes are always // reachable. Else the new tail is a better bet. p = (t != (t = tail)) ? t : head; else // Check for tail updates after two hops. p = (p != t && t != (t = tail)) ? t : q; } }
這個方法用於在佇列的尾部添加元素,這裡可以看到沒有加鎖,對於具體的無鎖演算法,採用的是Michael-Scott提出的非阻塞鍊錶連結演算法。 。 。具體是怎麼樣子的,可以到《JAVA並發程式設計實戰》去看吧,有比較詳細的介紹。
另外對於其他方法,其實都是採用無鎖的方式實現的。
最後,在實際的程式設計中,在並發環境中最好還是採用這些無鎖的實現,畢竟它的伸縮性更好。
總結
#以上是Java實作cas指令的無鎖程式設計的實例的詳細內容。更多資訊請關注PHP中文網其他相關文章!