ConcurrentModificationException异常总结-多线程方式

发表于 | 阅读数

1、多线程方式发生异常举例

1.1、java代码如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
final List<String> myList = createTestData();
new Thread(new Runnable() {
	@Override
	public void run() {
		for (String string : myList) {
			System.out.println("遍历集合 value = " + string);
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}).start();
new Thread(new Runnable() {
	@Override
	public void run() {
		for (Iterator<String> it = myList.iterator(); it.hasNext();) {
			String value = it.next();
			System.out.println("删除元素 value = " + value);
			if (value.equals("3")) {
				it.remove();
			}
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}).start();

1.2、异常信息打印如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
遍历集合 value = 1
删除元素 value = 1
删除元素 value = 2
遍历集合 value = 2
遍历集合 value = 3
删除元素 value = 3
删除元素 value = 4
Exception in thread "Thread-0" java.util.ConcurrentModificationException
	at java.util.AbstractList$Itr.checkForComodification(AbstractList.java:372)
	at java.util.AbstractList$Itr.next(AbstractList.java:343)
	at com.primeton.test.Test$1.run(Test.java:119)
	at java.lang.Thread.run(Thread.java:619)
删除元素 value = 5

当方法检测到对象的并发修改，但不允许这种修改时，抛出此异常。说明以上办法在同一个线程执行的时候是没问题的，但是在异步情况下依然可能出现异常。

2、解决办法

2.1、采用以下代码，将不会出现之前的异常

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
final List<String> myList = new CopyOnWriteArrayList<String>();
myList.add("1");
myList.add("2");
myList.add("3");
myList.add("4");
myList.add("5");
new Thread(new Runnable() {
	@Override
	public void run() {
		for (String string : myList) {
			System.out.println("遍历集合 value = " + string);
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}).start();
new Thread(new Runnable() {
	@Override
	public void run() {
		for (int i = 0; i < myList.size(); i++) {
			String value = myList.get(i);
			System.out.println("删除元素 value = " + value);
			if (value.equals("3")) {
				myList.remove(value);
				i--; // 注意
			}
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}).start();

2.2、输出结果

1
2
3
4
5
6
7
8
9
10
遍历集合 value = 1
删除元素 value = 1
遍历集合 value = 2
删除元素 value = 2
遍历集合 value = 3
删除元素 value = 3
遍历集合 value = 4
删除元素 value = 4
遍历集合 value = 5
删除元素 value = 5

3、相关总结

1、使用Collections.synchornizedXxx方法，获得线程安全对象
2、使用java.util.concurrent/java.util.concurrent.atomic并发编程对象开发
另附java中线程安全的类：HashTable、Vector、Stack、StringBuffer等