阿du曾经在面试的时候,遇到面试官问这样的问题,平时学习工作中都遇到过哪些Java异常信息,这时候我们不要只是说一些空指针、数组下标越界、类型转换等这些太常见的异常信息,如果能提到题目中ConcurrentModificationException并发修改异常,说不定能让面试官眼前一亮,哇 这小伙看来有多线程高并发方面的经验。下面说不定就会与你就并发修改异常详细唠唠,下面阿du将带大家看看如何一步步征服面试官。首先并发修改异常情景再现:
Listlist = new ArrayList<>(); for(int i=0;i<30;i++){ int finalI = i; new Thread(()->{ list.add(finalI); System.out.println(list); },String.valueOf(i)).start(); }
运行报错信息如下:
Exception in thread "main" java.util.ConcurrentModificationException at java.util.ArrayList$Itr.checkForComodification(ArrayList.java:909) at java.util.ArrayList$Itr.next(ArrayList.java:859)
可以看报错信息确实是并发修改异常,原因大伙都知道ArrayList是线程不安全的集合类,那么在进行多线程并发 *** 作的时候会出问题。那么我们该如何解决此类问题呢?可能有同学会说既然ArrayList是线程不安全的集合类,那么我用线程安全的Vector不就可以了嘛,翻看下源码,看看它的add方法:
public synchronized boolean add(E e) { modCount++; ensureCapacityHelper(elementCount + 1); elementData[elementCount++] = e; return true; }
可以看到简单粗暴直接在方法上面加了synchronized锁,虽然可以保证线程安全,但是会很大程度影响并发效率,肯定不能让面试官满意。也有的同学会说我可以用
Collections.synchronizedList(new ArrayList<>());
确实可以,但有没有更优的处理方式呢?接下来就需要CopyOnWriteArrayList出场了,它是JUC并发包下的,写时复制,主要是一种读写分离的思想,当需要读取元素的时候可以进行并发的读,当往一个容器中添加元素的时候加锁独占,而且不直接往当前容器Object[]添加,而是先将Object[]进行copy,复制出一个新的容器object[] newElements,然后向新的容器 newElements里添加元素,添加完,在将原容器的引用指向新的容器,源码和解读如下:
public boolean add(E e) { final ReentrantLock lock = this.lock; //写时加锁独占 lock.lock(); try { //获取原容器元素 Object[] elements = getArray(); //获取原容器长度 int len = elements.length; //复制一份 并扩容加1 Object[] newElements = Arrays.copyOf(elements, len + 1); //将要添加的元素添加到新复制的容器中 newElements[len] = e; //将原地址指向新的容器 setArray(newElements); return true; } finally { lock.unlock(); } }
这样循序渐进, 一定可以让面试官眼前一亮,接着我们可以举一反三,其实对于HashSet、HashMap也都是非线程安全的集合类,它们也都有对应线程安全的替换方案Collections.synchronizedSet(new HashSet<>())、CopyOnWriteArraySet、Collections.synchronizedMap(new HashMap<>())、ConcurrentHashMap;好啦 本次分享就到这里,感谢大家三连,我们下期见!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)