CopyOnWriteList是一個Java集合,他提供了並發讀,並且寫操作不會阻塞讀線程的列表。在JDK 1.5中推出,由於其出色的線程安全和高效性,CopyOnWriteList在高並發的場景中經常使用。
一、copyonwritelist 頻繁讀寫
CopyOnWriteList支持高並發場景下的頻繁讀取和較少寫入操作。CopyOnWriteList內部通過複製整個列表來實現線程安全的寫操作,並且寫操作不阻塞讀操作,讀操作不加鎖,提高了讀取效率。而寫操作發生時,需要對整個列表進行複製,會造成額外的空間開銷,因此不適合數據量大或者寫操作頻繁的場景。
二、copyonwritelist線程安全
CopyOnWriteList使用“寫時複製”的策略,讀取操作與寫入操作不互斥,讀操作不需要加鎖,寫操作在創建新集合時進行加鎖,並將引用指向新集合,使得新數據能夠被讀寫線程共享。因此,CopyOnWriteList的線程安全性得到了保障。
/**
* CopyOnWriteList線程安全性測試程序
*/
public class CopyOnWriteListTest {
private static final int THREAD_COUNT = 10;
private static final int ITEM_COUNT = 1000;
private List list = new CopyOnWriteArrayList();
private class ThreadReader extends Thread {
@Override
public void run() {
for (int i = 0; i < ITEM_COUNT; i++) {
int val = list.get(i);
System.out.println(Thread.currentThread().getName() + ":" + val);
}
}
}
private class ThreadWriter extends Thread {
@Override
public void run() {
for (int i = 0; i < ITEM_COUNT; i++) {
int val = (int) Math.round(Math.random() * ITEM_COUNT);
list.add(val);
System.out.println(Thread.currentThread().getName() + ": write " + val);
}
}
}
@Test
public void testCopyOnWriteList() throws InterruptedException {
for (int i = 0; i < ITEM_COUNT; i++) {
list.add(i);
}
//啟動10個線程進行讀操作
for (int i = 0; i < THREAD_COUNT; i++) {
ThreadReader reader = new ThreadReader();
reader.start();
}
//啟動1個線程進行寫操作
ThreadWriter writer = new ThreadWriter();
writer.start();
writer.join();
System.out.println("CopyOnWriteList size: " + list.size());
}
}
三、copyonwritelist效率
CopyOnWriteList的效率相對於其他同類型的集合要稍弱,主要原因是寫操作需要複製整個列表,因此在寫入操作非常頻繁的情況下,會造成較大的額外開銷。但是,在讀操作非常頻繁,且寫操作較少的場景中,CopyOnWriteList運行效率明顯高於其他同類型的集合。
四、copyonwritelist應用場景選取
CopyOnWriteList適用於讀操作較為頻繁,而寫操作較少,且內存佔用不是很重要的情況下。比如,緩存系統中的讀操作,通常有多個線程同時讀取。當有線程進行寫操作時,CopyOnWriteList將會複製一份全新的數據集合進行修改,而此時讀取的線程仍然可以讀取舊數據集合中的內容,保證了讀數據的一致性和讀空間的隔離性。
/**
* CopyOnWriteList應用場景測試程序
*/
public class CopyOnWriteListTest {
private static final int THREAD_COUNT = 10;
private static final int ITEM_COUNT = 1000;
private List list = new CopyOnWriteArrayList();
private class ThreadReader extends Thread {
@Override
public void run() {
for (int i = 0; i < ITEM_COUNT; i++) {
int val = list.get(i);
System.out.println(Thread.currentThread().getName() + ":" + val);
}
}
}
private class ThreadWriter extends Thread {
@Override
public void run() {
for (int i = 0; i < ITEM_COUNT; i++) {
int val = (int) Math.round(Math.random() * ITEM_COUNT);
list.add(val);
System.out.println(Thread.currentThread().getName() + ": write " + val);
}
}
}
@Test
public void testCopyOnWriteList() throws InterruptedException {
for (int i = 0; i < ITEM_COUNT; i++) {
list.add(i);
}
//啟動10個線程進行讀操作
for (int i = 0; i < THREAD_COUNT; i++) {
ThreadReader reader = new ThreadReader();
reader.start();
}
//啟動1個線程進行寫操作
ThreadWriter writer = new ThreadWriter();
writer.start();
writer.join();
System.out.println("CopyOnWriteList size: " + list.size());
}
}
五、總結
CopyOnWriteList的優點在於線程安全,可以在高並發的讀取操作下保證數據一致性和讀空間的隔離性。但是,如果寫操作比例過於頻繁,或者數據量過大,會造成額外的開銷,性能得不到保障。需要在合適的場景中進行選擇。
原創文章,作者:小藍,如若轉載,請註明出處:https://www.506064.com/zh-hant/n/205842.html
微信掃一掃
支付寶掃一掃