您好,登录后才能下订单哦!
这篇文章主要为大家展示了“List集合多线程并发条件下不安全怎么办”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“List集合多线程并发条件下不安全怎么办”这篇文章吧。
在日常开发过程中,List是我们常用的集合,比如查询数据库内容返回值比会用一个集合来装,但是在多线程并发的条件下,会出现安全问题吗?下面我们就来测试一下,如果出现安全问题,该如何解决.
public static void main(String[] args) { // List集合 List<String> list = new ArrayList<>(); // 循环插入 for (int i = 0; i < 10; i++) { list.add(UUID.randomUUID().toString().substring(0,5)); System.out.println(list); } }
可以看到单线程条件下,我们做list的插入操作完全没问题,下面我们来模拟并发条件下执行,会出现什么问题。
public static void main(String[] args) { // List集合 List<String> list = new ArrayList<>(); // 循环插入 for (int i = 0; i < 10; i++) { // 开启线程执行 new Thread(()->{ list.add(UUID.randomUUID().toString().substring(0,5)); System.out.println(list); },"线程List").start(); } }
ArrayList在迭代的时候如果同时对其进行修改就会抛出java.util.ConcurrentModificationException异常,就是并发修改异常。
public static void main(String[] args) { // List集合 List<String> list = new Vector<>(); // 循环插入 for (int i = 0; i < 10; i++) { // 开启线程执行 new Thread(()->{ list.add(UUID.randomUUID().toString().substring(0,5)); System.out.println(list); },"线程List").start(); } }
Vector 是同步访问的,它的add方法底层加了synchronized关键字修饰。
测试结果:
public static void main(String[] args) { // List集合 List<String> list = Collections.synchronizedList(new ArrayList<>()); // 循环插入 for (int i = 0; i < 10; i++) { // 开启线程执行 new Thread(()->{ list.add(UUID.randomUUID().toString().substring(0,5)); System.out.println(list); },"线程List").start(); } }
查看底层源码可以发现他也使用了synchronized关键字修饰。
public static void main(String[] args) { // List集合 List<String> list = new CopyOnWriteArrayList<>(); // 循环插入 for (int i = 0; i < 10; i++) { // 开启线程执行 new Thread(()->{ list.add(UUID.randomUUID().toString().substring(0,5)); System.out.println(list); },"线程List").start(); } }
查看源码它使用的是lock锁机制。
写入时复制,有多个线程调用的时候,写入的时候,复制一份,避免覆盖造成数据问题。就是在写的时候不对原集合进行修改,而是重新复制一份,修改完之后,再移动指针。
从JDK1.5开始Java并发包里提供了两个使用CopyOnWrite机制实现的并发容器,它们是CopyOnWriteArrayList和CopyOnWriteArraySet。CopyOnWrite容器非常有用,可以在非常多的并发场景中使用到。
解读源码:
/** * Appends the specified element to the end of this list. * * @param e element to be appended to this list * @return {@code true} (as specified by {@link Collection#add}) */ public boolean add(E e) { final ReentrantLock lock = this.lock;//可重入锁 lock.lock();//加锁 try { Object[] elements = getArray(); int len = elements.length; Object[] newElements = Arrays.copyOf(elements, len + 1);//拷贝新数组 newElements[len] = e; setArray(newElements);//将引用指向新数组 return true; } finally { lock.unlock();//解锁 } }
add()在添加集合的时候加上了锁,保证了同步,避免了多线程写的时候会Copy出N个副本出来。
以上是“List集合多线程并发条件下不安全怎么办”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。