qileilove

          blog已經(jīng)轉(zhuǎn)移至github,大家請?jiān)L問 http://qaseven.github.io/

          JAVA并發(fā)編程學(xué)習(xí)筆記之CAS操作

           CAS操作
            CAS是單詞compare and set的縮寫,意思是指在set之前先比較該值有沒有變化,只有在沒變的情況下才對其賦值。
            我們常常做這樣的操作
            if(a==b) {
            a++;
            }
            試想一下如果在做a++之前a的值被改變了怎么辦?a++還執(zhí)行嗎?出現(xiàn)該問題的原因是在多線程環(huán)境下,a的值處于一種不定的狀態(tài)。采用鎖可以解決此類問題,但CAS也可以解決,而且可以不加鎖。
          int expect = a;
          if(a.compareAndSet(expect,a+1)) {
          doSomeThing1();
          } else {
          doSomeThing2();
          }
            這樣如果a的值被改變了a++就不會被執(zhí)行。
            按照上面的寫法,a!=expect之后,a++就不會被執(zhí)行,如果我們還是想執(zhí)行a++操作怎么辦,沒關(guān)系,可以采用while循環(huán)
          while(true) {
          int expect = a;
          if (a.compareAndSet(expect, a + 1)) {
          doSomeThing1();
          return;
          } else {
          doSomeThing2();
          }
          }
            采用上面的寫法,在沒有鎖的情況下實(shí)現(xiàn)了a++操作,這實(shí)際上是一種非阻塞算法。
            應(yīng)用
             java.util.concurrent.atomic包中幾乎大部分類都采用了CAS操作,以AtomicInteger為例,看看它幾個主要方法的實(shí)現(xiàn):
          public final int getAndSet(int newValue) {
          for (;;) {
          int current = get();
          if (compareAndSet(current, newValue))
          return current;
          }
          }
            getAndSet方法JDK文檔中的解釋是:以原子方式設(shè)置為給定值,并返回舊值。原子方式體現(xiàn)在何處,就體現(xiàn)在compareAndSet上,看看compareAndSet是如何實(shí)現(xiàn)的:
            public final boolean compareAndSet(int expect, int update) {
            return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
            }
            不出所料,它就是采用的Unsafe類的CAS操作完成的。


            再來看看a++操作是如何實(shí)現(xiàn)的:
          public final int getAndIncrement() {
          for (;;) {
          int current = get();
          int next = current + 1;
          if (compareAndSet(current, next))
          return current;
          }
          }
            幾乎和最開始的實(shí)例一模一樣,也是采用CAS操作來實(shí)現(xiàn)自增操作的。
            ++a操作和a++操作類似,只不過返回結(jié)果不同罷了
          public final int incrementAndGet() {
          for (;;) {
          int current = get();
          int next = current + 1;
          if (compareAndSet(current, next))
          return next;
          }
          }
            此外,java.util.concurrent.ConcurrentLinkedQueue類全是采用的非阻塞算法,里面沒有使用任何鎖,全是基于CAS操作實(shí)現(xiàn)的。CAS操作可以說是JAVA并發(fā)框架的基礎(chǔ),整個框架的設(shè)計都是基于CAS操作的。
            缺點(diǎn):
            1、ABA問題
            CAS操作容易導(dǎo)致ABA問題,也就是在做a++之間,a可能被多個線程修改過了,只不過回到了最初的值,這時CAS會認(rèn)為a的值沒有變。a在外面逛了一圈回來,你能保證它沒有做任何壞事,不能!!也許它討閑,把b的值減了一下,把c的值加了一下等等,更有甚者如果a是一個對象,這個對象有可能是新創(chuàng)建出來的,a是一個引用呢情況又如何,所以這里面還是存在著很多問題的,解決ABA問題的方法有很多,可以考慮增加一個修改計數(shù),只有修改計數(shù)不變的且a值不變的情況下才做a++,也可以考慮引入版本號,當(dāng)版本號相同時才做a++操作等,這和事務(wù)原子性處理有點(diǎn)類似!
            2、比較花費(fèi)CPU資源,即使沒有任何爭用也會做一些無用功。
            3、會增加程序測試的復(fù)雜度,稍不注意就會出現(xiàn)問題。
            總結(jié):
            可以用CAS在無鎖的情況下實(shí)現(xiàn)原子操作,但要明確應(yīng)用場合,非常簡單的操作且又不想引入鎖可以考慮使用CAS操作,當(dāng)想要非阻塞地完成某一操作也可以考慮CAS。不推薦在復(fù)雜操作中引入CAS,會使程序可讀性變差,且難以測試,同時會出現(xiàn)ABA問題。

          posted on 2013-11-19 11:07 順其自然EVO 閱讀(220) 評論(0)  編輯  收藏


          只有注冊用戶登錄后才能發(fā)表評論。


          網(wǎng)站導(dǎo)航:
           
          <2013年11月>
          272829303112
          3456789
          10111213141516
          17181920212223
          24252627282930
          1234567

          導(dǎo)航

          統(tǒng)計

          常用鏈接

          留言簿(55)

          隨筆分類

          隨筆檔案

          文章分類

          文章檔案

          搜索

          最新評論

          閱讀排行榜

          評論排行榜

          主站蜘蛛池模板: 巨鹿县| 广平县| 河池市| 宜春市| 阳城县| 华宁县| 西丰县| 招远市| 南雄市| 前郭尔| 昌平区| 柘荣县| 六安市| 湘潭市| 札达县| 临潭县| 肃宁县| 中超| 新巴尔虎左旗| 台安县| 太保市| 静海县| 会宁县| 固原市| 苍梧县| 高青县| 原平市| 三江| 个旧市| 光山县| 巴彦县| 嵩明县| 高安市| 牟定县| 高阳县| 上高县| 广昌县| 余干县| 西华县| 阳新县| 临颍县|