import java.util.Iterator;
import java.util.concurrent.CopyOnWriteArrayList;

/**
* 集合在多線程中同步的方式:
* 1. Collections.synchronizedMap()
* 2. Hashtable鎖機(jī)制: 將整個(gè)hash表鎖起來,多線程的并行變成串行,多線程效率低
* 3. (優(yōu)先選擇)ConcurrentHashMap鎖機(jī)制: 采用鎖分段機(jī)制, 效率高, 鎖分段實(shí)現(xiàn)線程的并行
* 結(jié)構(gòu) 每1個(gè)ConcurrentHashMap默認(rèn)有16個(gè)段(segment),
* 每1個(gè)段默認(rèn)有16長度的哈希表
* 哈希表的每個(gè)桶位都有1個(gè)鏈表
* 每個(gè)段(segmeng)有獨(dú)立的鎖,不同段之間的線程可以并行, 默認(rèn)16個(gè)段并行線程數(shù)量最高是16個(gè)
*
* 后期改進(jìn): 鎖分段換成了無鎖的效率更高的CAS算法(比較替換算法)
*
* 選擇方式:
* 單線程集合 多線程中集合
* 1. HashMap ConcurrentHashMap
* 2. TreeMap ConcurrentSkipListMap
* 3. ArrayList CopyOnWriteArrayList 寫入并復(fù)制
*
* CopyOnWriteArrayList: 添加操作多時(shí),效率低,因?yàn)槊看翁砑佣紩?huì)復(fù)制并創(chuàng)建新的集合,開銷大
* 適合場(chǎng)景: 多線程并發(fā)迭代集合
*/
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創(chuàng)建同步集合
// 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());
//在迭代方法中, 往集合中添加元素出現(xiàn)ConcurrentModificationException異常
//集合集合添加操作和迭代器遍歷操作使用的是同一個(gè)數(shù)據(jù)源(集合)
list.add("AAA");
}

}
}

轉(zhuǎn)載于:https://www.cnblogs.com/huangleshu/p/10028334.html

總結(jié)

以上是生活随笔為你收集整理的juc包下的集合类的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。