您好,登錄后才能下訂單哦!
java怎樣制作線程安全的計數器?相信大部分人都不太了解,今天小編為了讓大家更加了解java怎樣制作線程安全的計數器,給大家總結了以下內容,一起往下看吧。
線程安全的計數器實現原理簡介:
在java中volatile關鍵字可以保證共享數據的可見性,它會把更新后的數據從工作內存刷新進共享內存,并使其他線程中工作內存中的數據失效,進而從主存中讀入最新值來保證共享數據的可見性,實現線程安全的計數器通過循環CAS操作來實現。就是先獲取一個舊期望值值,再比較獲取的值與主存中的值是否一致,一致的話就更新,不一致的話接著循環,直到成功為止.
具體代碼實現
public class Count{ private int count = 0; private AtomicInteger atomicI = new AtomicInteger(0); public static void main(String[] args){ final Count cas = new Count(); List<Thread> list = new ArrayList<Thread>(); 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(); } //等待所有線程執行完畢 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)); } /**線程不安全的計數器*/ public void count(){ count++; } /**線程安全的計數器,循環CAS*/ public void safeCount(){ for(;;){ int temp = atomicI.get(); if(atomicI.compareAndSet(temp,++temp)) break; } } }
執行結果:
以上就是java如何實現線程安全的計數器的內容,有需要的朋友可以參考一下,望對大家有所幫助,更多請關注億速云其它相關文章!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。