十年網(wǎng)站開發(fā)經(jīng)驗 + 多家企業(yè)客戶 + 靠譜的建站團隊
量身定制 + 運營維護+專業(yè)推廣+無憂售后,網(wǎng)站問題一站解決
java怎樣制作線程安全的計數(shù)器?相信大部分人都不太了解,今天小編為了讓大家更加了解java怎樣制作線程安全的計數(shù)器,給大家總結(jié)了以下內(nèi)容,一起往下看吧。
成都創(chuàng)新互聯(lián)公司咨詢熱線:13518219792,為您提供成都網(wǎng)站建設(shè)網(wǎng)頁設(shè)計及定制高端網(wǎng)站建設(shè)服務(wù),成都創(chuàng)新互聯(lián)公司網(wǎng)頁制作領(lǐng)域十余年,包括玻璃鋼坐凳等多個方面擁有豐富設(shè)計經(jīng)驗,選擇成都創(chuàng)新互聯(lián)公司,為網(wǎng)站保駕護航!
線程安全的計數(shù)器實現(xiàn)原理簡介:
在java中volatile關(guān)鍵字可以保證共享數(shù)據(jù)的可見性,它會把更新后的數(shù)據(jù)從工作內(nèi)存刷新進共享內(nèi)存,并使其他線程中工作內(nèi)存中的數(shù)據(jù)失效,進而從主存中讀入最新值來保證共享數(shù)據(jù)的可見性,實現(xiàn)線程安全的計數(shù)器通過循環(huán)CAS操作來實現(xiàn)。就是先獲取一個舊期望值值,再比較獲取的值與主存中的值是否一致,一致的話就更新,不一致的話接著循環(huán),直到成功為止.
具體代碼實現(xiàn)
public class Count{ private int count = 0; private AtomicInteger atomicI = new AtomicInteger(0); public static void main(String[] args){ final Count cas = new Count(); Listlist = new ArrayList (); long start = System.currentTimeMillis(); for(int j=0;j<100;j++){ Thread t = new Thread(new Runnable(){ @Override public void run(){ for(int i=0;i<1000;i++){ cas.count(); cas.safeCount(); } } }); list.add(t); } //啟動線程 for(Thread t:list){ t.start(); } //等待所有線程執(zhí)行完畢 for(Thread t:list){ try{ t.join(); }catch(Exception e){ e.printStackTrace(); } } System.out.println("線程不安全:"+cas.count); System.out.println("線程安全:"+cas.atomicI.get()); System.out.println("耗時:"+(System.currentTimeMillis() - start)); } /**線程不安全的計數(shù)器*/ public void count(){ count++; } /**線程安全的計數(shù)器,循環(huán)CAS*/ public void safeCount(){ for(;;){ int temp = atomicI.get(); if(atomicI.compareAndSet(temp,++temp)) break; } } }
執(zhí)行結(jié)果:
以上就是java如何實現(xiàn)線程安全的計數(shù)器的內(nèi)容,有需要的朋友可以參考一下,望對大家有所幫助,更多請關(guān)注創(chuàng)新互聯(lián)其它相關(guān)文章!