Java高级_JUC

发表于 | 更新于 | 分类于 | 阅读次数：
本文字数： 5.5k | 阅读时长 ≈ 5 分钟

并发

  1. java.util.concurrent. 并发—->充分利用CPU的资源
  2. java.util.concurrent.atomic 原子性
  3. java.util.concurrent.locks 锁

对于锁,可以去看一下<Java中级-多线程一二三>,以后在整理好,抱歉

现在主要讲的是并发下,集合 List, Set , Map的安全问题

对于List集合

先看一个List<String> list = new ArrayList<String>();

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
public static void listSate() {

		List<String> list = new ArrayList<String>();
		// 单线程添加数据
		for (int i = 0; i < 10; i++) {
			list.add(UUID.randomUUID().toString().substring(0, 3));
			System.out.println(list);
		}
		System.out.println("单线程正常添加10个数据:" + list.size());
		System.out.println("===========================================");

		// 多线程添加数据
		List<String> listThread = new ArrayList<String>(); // 不安全
		Thread[] ts = new Thread[10];
		for (int i = 0; i < 10; i++) {
			Thread t = new Thread(() -> {
				listThread.add(UUID.randomUUID().toString().substring(0, 3));
				System.out.println(Thread.currentThread().getId() + "多线程添加数据: \n" + listThread);
			}, "线程" + i);
			ts[i] = t;
			t.start();
		}
		for (Thread t : ts) {
			try {
				t.join();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		System.out.println("多线程正常添加10个数据:" + listThread.size());
		System.out.println("多线程正常添加10个数据:" + listThread);

	}

结果:

[67a]
[67a, 501]
[67a, 501, a85]
[67a, 501, a85, 934]
[67a, 501, a85, 934, e9d]
[67a, 501, a85, 934, e9d, e6c]
[67a, 501, a85, 934, e9d, e6c, 402]
[67a, 501, a85, 934, e9d, e6c, 402, 016]
[67a, 501, a85, 934, e9d, e6c, 402, 016, 24b]
[67a, 501, a85, 934, e9d, e6c, 402, 016, 24b, be6]

单线程正常添加10个数据:10

15多线程添加数据:
[8a0, bfe]
14多线程添加数据:
[8a0, bfe]
16多线程添加数据:
[8a0, bfe, 556]
17多线程添加数据:
[8a0, bfe, 556, 8f9, ef1]
Exception in thread “线程4” Exception in thread “线程7” Exception in thread “线程8” 19多线程添加数据:
[8a0, bfe, 556, 8f9, ef1, ac1]
23多线程添加数据:
[8a0, bfe, 556, 8f9, ef1, ac1, e8d, 512, 348]
20多线程添加数据:
[8a0, bfe, 556, 8f9, ef1, ac1, e8d, 512, 348, 444]
java.util.ConcurrentModificationException
at java.util.ArrayList$Itr.checkForComodification(ArrayList.java:901)
at java.util.ArrayList$Itr.next(ArrayList.java:851)
at java.util.AbstractCollection.toString(AbstractCollection.java:461)

最后发现,在多线程操作的时候,报了ConcurrentModificationException异常 ( 翻译过来就是 并发修改异常 )

解决办法:

三种:

1
2
3
List<String> listThread =Collections.synchronizedList(new ArrayList<String>()); // 安全
List<String> listThread = new Vector<String>(); // 安全
List<String> listThread = new CopyOnWriteArrayList<String>(); // 安全

第一种: 采用集合工具类提供的安全方法Collections.synchronizedList()

第二种是使用List 的子类 Vector 是支持同步的

第三种是使用CopyOnWriteArrayList类

结果就是 :不报异常

对于Set集合

先看一个:

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
public static void SetSafe() {
		Set<String> set = new HashSet<String>();
		for (int i = 0; i < 10; i++) {
			set.add(UUID.randomUUID().toString().substring(0, 3));
			System.out.println(set);
		}
		System.out.println("单线程正常添加10个数据:" + set.size());
		System.out.println("===========================================");

		/Set<String> setTread = new HashSet<String>(); // 不安全
		Thread[] ts = new Thread[10];
		for (int i = 0; i < 10; i++) {
			Thread t = new Thread(() -> {
				setTread.add(UUID.randomUUID().toString().substring(0, 3));
				System.out.println(Thread.currentThread().getId() + "多线程添加数据: \n" + setTread);
			}, "线程" + i);
			ts[i] = t;
			t.start();
		}
		for (Thread t : ts) {
			try {
				t.join();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		System.out.println("多线程正常添加10个数据:" + setTread.size());
		System.out.println("多线程正常添加10个数据:" + setTread);
	}

结果:

同样是抛出异常

ConcurrentModificationException

解决办法:

两种:

1
2
Set<String> setTread = Collections.synchronizedSet(new HashSet<String>()); // 安全
Set<String> setTread = new CopyOnWriteArraySet<String>(); // 安全

第一种: 采用Collections集合工具类提供的Collections.synchronizedSet()方法

第二章:采用CopyOnWriteArraySet类

结果就是不报异常

对于Map集合

先看一个

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
public static void mapSafe() {
		Map<String, String> map = new HashMap<String, String>();
		for (int i = 0; i < 10; i++) {
			map.put(Thread.currentThread().getName(), UUID.randomUUID().toString().substring(0, 3));
			System.out.println(map);
		}
		System.out.println("单线程正常添加10个数据:" + map.size());
		System.out.println("===========================================");

		Map<String, String> mapTread = new HashMap<String, String>(); 不安全
		Thread[] ts = new Thread[10];
		for (int i = 0; i < 10; i++) {
			Thread t = new Thread(() -> {
				mapTread.put(Thread.currentThread().getName(), UUID.randomUUID().toString().substring(0, 3));
				System.out.println(mapTread.values());
			}, "线程" + i);
			ts[i] = t;
			t.start();
		}
		for (Thread t : ts) {
			try {
				t.join();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		System.out.println("多线程正常添加10个数据:" + mapTread.size());
	}

结果:

报异常

解决办法两个

1
2
3
Map<String, String> mapTread = new Hashtable<String, String>(); // 安全
Map<String, String> mapTread = Collections.synchronizedMap(new HashMap<String, String>()); // 安全
Map<String, String> mapTread = new ConcurrentHashMap<String, String>(); // 安全

第一种:采用Map的子类HashTable

第二种:采用集合工具类Collections.synchronizedMap()

第三种:采用 ConcurrentHashMap 类

小唠嗑：

本章到这里就结束了，谢谢耐心看到这里的各位Boss,如果觉得有哪里说的不好的地方，还请高抬贵手多多原谅，不惜指教。

最后，谢谢！

---本文结束感谢您的阅读!---