Java JUC中操作List安全類(lèi)的集合案例
在單線程應(yīng)用中,通常采取new ArrayList(),指定一個(gè)List集合,用于存放可重復(fù)的數(shù)據(jù)。
但在多線程下,往往會(huì)出現(xiàn)意想不到的問(wèn)題,代碼如下所示:
import java.util.*;public class ListTest { public static void main(String[] args) throws InterruptedException {// 創(chuàng)建list集合//List<String> lists = Arrays.asList('1', '2', '3');// 不安全List<String> lists = new ArrayList<>();// 開(kāi)啟十個(gè)線程增加數(shù)據(jù)for (int i = 1; i <= 40; i++) { new Thread(()->{lists.add(UUID.randomUUID().toString().substring(0,5));System.out.println(Thread.currentThread().getName()+'=='+lists); },String.valueOf(i)).start();} }}
其運(yùn)行結(jié)果如下所示:
多線程操作同一集合對(duì)象信息,往往會(huì)出現(xiàn)java.util.ConcurrentModificationException異常報(bào)錯(cuò)信息。
Java中提供的安全措施在java語(yǔ)言中,提供了一種新的List集合,java.util.Vector類(lèi),具體看下列代碼:
import java.util.*;public class ListTest { public static void main(String[] args) throws InterruptedException {// 創(chuàng)建list集合//List<String> lists = Arrays.asList('1', '2', '3');// 不安全//List<String> lists = new ArrayList<>();List<String> lists = new Vector<>();// 開(kāi)啟十個(gè)線程增加數(shù)據(jù)for (int i = 1; i <= 40; i++) { new Thread(()->{lists.add(UUID.randomUUID().toString().substring(0,5));System.out.println(Thread.currentThread().getName()+'=='+lists); },String.valueOf(i)).start();} }}
運(yùn)行日志如下所示:
不會(huì)出現(xiàn)java.util.ConcurrentModificationException報(bào)錯(cuò)信息。
為什么能保證數(shù)據(jù)的安全操作?
采取了 synchronized 針對(duì)方法執(zhí)行調(diào)用者加鎖,保證add操作的多線程安全性!
JUC下的安全List集合在JUC包下,提供有以下幾種創(chuàng)建安全集合的方式。
方式一:Collections.synchronizedList(new ArrayList<>());import java.util.*;public class ListTest { public static void main(String[] args) throws InterruptedException {List<String> lists = Collections.synchronizedList(new ArrayList<>());// 開(kāi)啟十個(gè)線程增加數(shù)據(jù)for (int i = 1; i <= 40; i++) { new Thread(()->{lists.add(UUID.randomUUID().toString().substring(0,5));System.out.println(Thread.currentThread().getName()+'=='+lists); },String.valueOf(i)).start();} }}
查看底層源碼實(shí)現(xiàn)邏輯
判斷傳入的 list 集合類(lèi)型,判斷類(lèi)型是否為 java.util.RandomAccess,如果是則采取java.util.Collections.SynchronizedRandomAccessList構(gòu)造集合,如果不是則采取java.util.Collections.SynchronizedList構(gòu)造集合。
源碼中對(duì)應(yīng)的add操作邏輯如下所示:
采取synchronized同步代碼塊的方式,對(duì)數(shù)據(jù)的add操作實(shí)現(xiàn)加鎖!
方式二:new CopyOnWriteArrayList();import java.util.*;import java.util.concurrent.CopyOnWriteArrayList;public class ListTest { public static void main(String[] args) throws InterruptedException {List<String> lists = new CopyOnWriteArrayList<>();// 開(kāi)啟十個(gè)線程增加數(shù)據(jù)for (int i = 1; i <= 40; i++) { new Thread(()->{lists.add(UUID.randomUUID().toString().substring(0,5));System.out.println(Thread.currentThread().getName()+'=='+lists); },String.valueOf(i)).start();} }}
源碼中的介紹如下:
顯而易見(jiàn),其邏輯如下所示:
調(diào)用add方法后,拿到j(luò)ava.util.concurrent.locks.ReentrantLock對(duì)象信息。 調(diào)用 lock.lock() 拿到鎖! 將原數(shù)組對(duì)象copy操作,并創(chuàng)建原數(shù)組大小+1的新數(shù)組。 將新數(shù)據(jù)放入新數(shù)組中。 任何操作finally,都進(jìn)行鎖的釋放!性能方面JUC包下的Lock操作,都比synchronized性能更好!
到此這篇關(guān)于JUC中操作List安全類(lèi)的集合案例的文章就介紹到這了,更多相關(guān)JUC中List安全類(lèi)內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!
相關(guān)文章:
1. js實(shí)現(xiàn)跳一跳小游戲2. SpringBoot 開(kāi)發(fā)提速神器 Lombok+MybatisPlus+SwaggerUI3. 10個(gè)提供免費(fèi)PHP腳本下載的網(wǎng)站4. js實(shí)現(xiàn)貪吃蛇小游戲(加墻)5. 使用idea 去除 html 代碼前的行號(hào)和空行的方法詳解6. JVM之class文件結(jié)構(gòu)7. Python編寫(xiě)nmap掃描工具8. php5.6不能擴(kuò)展redis.so的解決方法9. PHP設(shè)計(jì)模式(四)原型模式Prototype實(shí)例詳解【創(chuàng)建型】10. python 爬取嗶哩嗶哩up主信息和投稿視頻
