Java JUC中操作List安全类的集合案例
不安全的集合
在单线程应用中，通常采取new ArrayList()，指定一个List集合，用于存放可重复的数据。
但在多线程下，往往会出现意想不到的问题，代码如下所示：
import java.util.*;
public class ListTest {
public static void main(String[] args) throws InterruptedException {
// 创建list集合
//List<String> lists = Arrays.asList("1", "2", "3");
// 不安全
List<String> lists = new ArrayList<>();
// 开启十个线程增加数据
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();
}
}
}
其运行结果如下所示：
多线程操作同一集合对象信息，往往会出现java.util.ConcurrentModificationException异常报错信息。
Java中提供的安全措施
在java语言中，提供了一种新的List集合，java.util.Vector类，具体看下列代码：
import java.util.*;
public class ListTest {
public static void main(String[] args) throws InterruptedException {
// 创建list集合
//List<String> lists = Arrays.asList("1", "2", "3");
// 不安全
//List<String> lists = new ArrayList<>();
List<String> lists = new Vector<>();
// 开启十个线程增加数据
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();
}
}
}
运行日志如下所示：
不会出现java.util.ConcurrentModificationException报错信息。
为什么能保证数据的安全操作？
采取了 synchronized 针对方法执行调用者加锁，保证add操作的多线程安全性！
JUC下的安全List集合
在JUC包下，提供有以下几种创建安全集合的方式。
- 方式一：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<>());
// 开启十个线程增加数据
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();
}
}
}
查看底层源码实现逻辑
判断传入的 list 集合类型，判断类型是否为 java.util.RandomAccess，如果是则采取java.util.Collections.SynchronizedRandomAccessList构造集合，如果不是则采取java.util.Collections.SynchronizedList构造集合。
源码中对应的add操作逻辑如下所示：
采取synchronized同步代码块的方式，对数据的add操作实现加锁！
- 方式二：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<>();
// 开启十个线程增加数据
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();
}
}
}
源码中的介绍如下：
显而易见，其逻辑如下所示：
- 调用add方法后，拿到java.util.concurrent.locks.ReentrantLock对象信息。
- 调用 lock.lock() 拿到锁！
- 将原数组对象copy操作，并创建原数组大小+1的新数组。
- 将新数据放入新数组中。
- 任何操作finally，都进行锁的释放！
性能方面
JUC包下的Lock操作，都比synchronized性能更好！
到此这篇关于JUC中操作List安全类的集合案例的文章就介绍到这了,更多相关JUC中List安全类内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了Eclipse的Debug调试技巧大全（总结）,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-12-12
本文主要介绍了SpringBoot集成Redis实现验证码的缓存简单案例，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-07-07
这篇文章主要介绍了java背包问题动态规划算法分析，想了解算法的同学一定要看一下2021-04-04
SpringBoot项目中使用OkHttp获取IP地址的示例代码
OkHttp 是一个由 Square 开发的高效、现代的 HTTP 客户端库,用于 Android 和 Java 应用程序,它支持 HTTP/2 和 SPDY 等现代网络协议,并提供了多种功能和优化,本文给大家介绍了SpringBoot项目中如何获取IP地址,需要的朋友可以参考下2024-08-08
文章主要介绍了在审批成功后如何使用Kettle传递批次号参数并执行KTR文件,同时,提到了所需的主要POM依赖,并强调了个人经验的价值,鼓励大家参考和使用2025-01-01
IDEA 一直scanning files to index的四种完美解决方法(VIP典藏版)
这篇文章主要介绍了IDEA 一直scanning files to index的四种完美解决方法(VIP典藏版),推荐第四种方法,第四种方法摸索研究后得出,亲测好用,需要的朋友参考下吧2023-10-10
这篇文章主要介绍了Spring容器初始化及问题解决方案,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-06-06
给定一个只包括 '(',')','{','}','[',']' 的字符串 s ,判断字符串是否有效,有效字符串需要满足：左括号必须用相同类型的右括号闭合,这篇文章主要介绍了Java判断字符串是否是有效的括号,需要的朋友可以参考下2023-10-10
本文详细讲解了Java中Socket的用法，文中通过示例代码介绍的非常详细。对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-12-12
下面小编就为大家带来一篇Java无限级树(递归)超实用案例。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2016-11-11
最新评论