摘要:源碼和多線程安全問題分析在分析線程安全問題之前,我們線對此類的源碼進行分析,找出可能出現線程安全問題的地方,然后代碼進行驗證和分析。即當多線程調用方法的時候會出現元素覆蓋的問題。
1.ArrayList源碼和多線程安全問題分析
在分析ArrayList線程安全問題之前,我們線對此類的源碼進行分析,找出可能出現線程安全問題的地方,然后代碼進行驗證和分析。
1.1 數據結構ArrayList內部是使用數組保存元素的,數據定義如下:
transient Object[] elementData; // non-private to simplify nested class access
在ArrayList中此數組即是共享資源,當多線程對此數據進行操作的時候如果不進行同步控制,即有可能會出現線程安全問題。
1.2 add方法可能出現的問題分析首先我們看一下add的源碼如下:
public boolean add(E e) { ensureCapacityInternal(size + 1); elementData[size++] = e; return true; }
此方法中有兩個操作,一個是數組容量檢查,另外就是將元素放入數據中。我們先看第二個簡單的開始分析,當多個線程執行順序如下所示的時候,會出現最終數據元素個數小于期望值。
按照此順序執行完之后,我們可以看到,elementData[n]的只被設置了兩次,第二個線程設置的值將前一個覆蓋,最后size=n+1。下面使用代碼進行驗證此問題。
1.3 代碼驗證首先先看下以下代碼,開啟1000個線程,同時調用ArrayList的add方法,每個線程向ArrayList中添加100個數字,如果程序正常執行的情況下應該是輸出:
list size is :10000
代碼如下:
private static Listlist = new ArrayList (); private static ExecutorService executorService = Executors.newFixedThreadPool(1000); private static class IncreaseTask extends Thread{ @Override public void run() { System.out.println("ThreadId:" + Thread.currentThread().getId() + " start!"); for(int i =0; i < 100; i++){ list.add(i); } System.out.println("ThreadId:" + Thread.currentThread().getId() + " finished!"); } } public static void main(String[] args){ for(int i=0; i < 1000; i++){ executorService.submit(new IncreaseTask()); } executorService.shutdown(); while (!executorService.isTerminated()){ try { Thread.sleep(1000*10); }catch (InterruptedException e){ e.printStackTrace(); } } System.out.println("All task finished!"); System.out.println("list size is :" + list.size()); }
當執行此main方法后,輸出如下:
從以上執行結果來看,最后輸出的結果會小于我們的期望值。即當多線程調用add方法的時候會出現元素覆蓋的問題。
1.4 數組容量檢測的并發問題在add方法源碼中,我們看到在每次添加元素之前都會有一次數組容量的檢測,add中調用此方法的源碼如下:
ensureCapacityInternal(size + 1);
容量檢測的相關源碼如下:
private void ensureCapacityInternal(int minCapacity) { if (elementData == DEFAULTCAPACITY_EMPTY_ELEMENTDATA) { minCapacity = Math.max(DEFAULT_CAPACITY, minCapacity); } ensureExplicitCapacity(minCapacity); } private void ensureExplicitCapacity(int minCapacity) { modCount++; // overflow-conscious code if (minCapacity - elementData.length > 0) grow(minCapacity); }
容量檢測的流程圖如下所示:
我們以兩個線程執行add操作來分析擴充容量可能會出現的并發問題:
當我們新建一個ArrayList時候,此時內部數組容器的容量為默認容量10,當我們用兩個線程同時添加第10個元素的時候,如果出現以下執行順序,可能會拋出java.lang.ArrayIndexOutOfBoundsException異常。
第二個線程往數組中添加數據的時候由于數組容量為10,而此操作往index為10的位置設置元素值,因此會拋出數組越界異常。
1.5 代碼驗證數組容量檢測的并發問題使用如下代碼:
private static Listlist = new ArrayList (3); private static ExecutorService executorService = Executors.newFixedThreadPool(10000); private static class IncreaseTask extends Thread{ @Override public void run() { System.out.println("ThreadId:" + Thread.currentThread().getId() + " start!"); for(int i =0; i < 1000000; i++){ list.add(i); } System.out.println("ThreadId:" + Thread.currentThread().getId() + " finished!"); } } public static void main(String[] args){ new IncreaseTask().start(); new IncreaseTask().start(); }
執行main方法后,我們可以看到控制臺輸出如下:
ArrayList中其他包含對共享變量操作的方法同樣會有并發安全問題,只需要按照以上的分析方法分析即可。
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://m.specialneedsforspecialkids.com/yun/67638.html
摘要:今天主要講解的是本文力求簡單講清每個知識點,希望大家看完能有所收獲一和回顧線程安全的和我們知道是用于替代的,是線程安全的容器。使用迭代器遍歷時不需要顯示加鎖,看看與方法的實現可能就有點眉目了。 前言 只有光頭才能變強 showImg(https://segmentfault.com/img/remote/1460000016931828?w=1120&h=640); 前一陣子寫過一篇C...
摘要:常用集合使用場景分析過年前的最后一篇,本章通過介紹,,,底層實現原理和四個集合的區別。和都是線程安全的,不同的是前者使用類,后者使用關鍵字。面試官會認為你是一個基礎扎實,內功深厚的人才到這里常用集合使用場景分析就結束了。 Java 常用List集合使用場景分析 過年前的最后一篇,本章通過介紹ArrayList,LinkedList,Vector,CopyOnWriteArrayList...
摘要:而且只要他更新完畢對修飾的變量賦值,那么讀線程立馬可以看到最新修改后的數組,這是保證的。這個時候,就采用了思想來實現這個,避免更新的時候阻塞住高頻的讀操作,實現無鎖的效果,優化線程并發的性能。 今天聊一個非常硬核的技術知識,給大家分析一下CopyOnWrite思想是什么,以及在Java并發包中的具體體現,包括在Kafka內核源碼中是如何運用這個思想來優化并發性能的。這個CopyOnW...
摘要:學習編程的本最佳書籍這些書涵蓋了各個領域,包括核心基礎知識,集合框架,多線程和并發,內部和性能調優,設計模式等。擅長解釋錯誤及錯誤的原因以及如何解決簡而言之,這是學習中并發和多線程的最佳書籍之一。 showImg(https://segmentfault.com/img/remote/1460000018913016); 來源 | 愿碼(ChainDesk.CN)內容編輯 愿碼Slo...
閱讀 3326·2021-11-08 13:12
閱讀 2766·2021-10-15 09:41
閱讀 1459·2021-10-08 10:05
閱讀 3306·2021-10-08 10:04
閱讀 2114·2021-09-29 09:34
閱讀 2488·2019-08-30 15:55
閱讀 2985·2019-08-30 15:45
閱讀 2594·2019-08-29 14:17