juc包下的集合类
import java.util.Iterator;
import java.util.concurrent.CopyOnWriteArrayList;
/**
* 集合在多線程中同步的方式:
* 1. Collections.synchronizedMap()
* 2. Hashtable鎖機制: 將整個hash表鎖起來,多線程的并行變成串行,多線程效率低
* 3. (優先選擇)ConcurrentHashMap鎖機制: 采用鎖分段機制, 效率高, 鎖分段實現線程的并行
* 結構 每1個ConcurrentHashMap默認有16個段(segment),
* 每1個段默認有16長度的哈希表
* 哈希表的每個桶位都有1個鏈表
* 每個段(segmeng)有獨立的鎖,不同段之間的線程可以并行, 默認16個段并行線程數量最高是16個
*
* 后期改進: 鎖分段換成了無鎖的效率更高的CAS算法(比較替換算法)
*
* 選擇方式:
* 單線程集合 多線程中集合
* 1. HashMap ConcurrentHashMap
* 2. TreeMap ConcurrentSkipListMap
* 3. ArrayList CopyOnWriteArrayList 寫入并復制
*
* CopyOnWriteArrayList: 添加操作多時,效率低,因為每次添加都會復制并創建新的集合,開銷大
* 適合場景: 多線程并發迭代集合
*/
public class ConcurrenCollectionTest {
public static void main(String[] args) {
ArrayListTask listTask = new ArrayListTask();
for (int i = 0; i < 10; i++) {
new Thread(listTask).start();
}
}
}
class ArrayListTask implements Runnable{
//Collections.synchronizedList創建同步集合
// private static List<String> list = Collections.synchronizedList(new ArrayList <>());
private static CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList();
static {
list.add("AAA");
list.add("BBB");
list.add("CCC");
}
@Override
public void run() {
Iterator<String> it = list.iterator();
while (it.hasNext()) {
System.out.println(it.next());
//在迭代方法中, 往集合中添加元素出現ConcurrentModificationException異常
//集合集合添加操作和迭代器遍歷操作使用的是同一個數據源(集合)
list.add("AAA");
}
}
}
轉載于:https://www.cnblogs.com/huangleshu/p/10028334.html
總結
- 上一篇: c++ 学习链接
- 下一篇: android学习日记12--布局管理器