public class Test {public static void main(String[] args) {Setset = new HashSet<>();
for (int i = 1; i< 100; i++) {new Thread(() ->{// 寫(xiě)入
set.add(UUID.randomUUID().toString().substring(0, 8));
// 讀出
System.out.println(set);
}, String.valueOf(i)).start();
}
}
}
報(bào)錯(cuò):
報(bào)錯(cuò)說(shuō)明:
會(huì)出現(xiàn)java.util.ConcurrentModificationException,該異常俗稱(chēng)并發(fā)修改異常,即多個(gè)線程需要寫(xiě)入,同時(shí)還有多個(gè)線程還要讀出,所以會(huì)出現(xiàn)該異常
hashset底層另外還需要說(shuō)明的一點(diǎn)是HashSet的底層是HashMap,可以看源碼:
public HashSet() {map = new HashMap<>();
}
解決辦法
方法一:使用Collections.synchronizedSet(new HashSet<>())(適合低并發(fā)小數(shù)據(jù)量的時(shí)候使用)// 除了這一行之外,其他代碼的和上面“1、HashSet不安全嗎?”中的測(cè)試代碼相同
Setset = Collections.synchronizedSet(new HashSet<>());
說(shuō)明:
可以把線程不安全的HashSet對(duì)象變成線程安全的對(duì)象,其實(shí)就是對(duì)HashSet中的每個(gè)方法上加synchronized
測(cè)試代碼:
import java.util.Collections;
import java.util.HashSet;
import java.util.Set;
import java.util.UUID;
public class SetUnsefertyTest {public static void main(String[] args) {// Setset = new HashSet<>();
Setset = Collections.synchronizedSet(new HashSet<>()) ;
for (int i = 1; i< 100; i++) {new Thread(() ->{// 寫(xiě)入
set.add(UUID.randomUUID().toString().substring(0, 8));
// 讀出
System.out.println(set);
}, String.valueOf(i)).start();
}
}
}
方案2:使用CopyOnWriteArraySet代替HashSet(適合多線程高并發(fā)大數(shù)據(jù)量的時(shí)候使用)// 除了這一行之外,其他代碼的和上面“1、HashSet不安全嗎?”中的測(cè)試代碼相同
Setset = new CopyOnWriteArraySet<>();
說(shuō)明:
首先CopyOnWriteArraySet的add()方法:
public boolean add(E e) {return al.addIfAbsent(e);
}
然后點(diǎn)擊addIfAbsent()就到了CopyOnWriteArrayList類(lèi)中
public boolean addIfAbsent(E e) {Object[] snapshot = getArray();
return indexOf(e, snapshot, 0, snapshot.length) >= 0 ? false :
addIfAbsent(e, snapshot);
}
之后我們點(diǎn)擊addIfAbsent()方法后發(fā)現(xiàn)CopyOnWriteArrayList類(lèi)中的該方法內(nèi)部代碼
private boolean addIfAbsent(E e, Object[] snapshot) {final ReentrantLock lock = this.lock;
lock.lock();
try {Object[] current = getArray();
int len = current.length;
if (snapshot != current) {// Optimize for lost race to another addXXX operation
int common = Math.min(snapshot.length, len);
for (int i = 0; i< common; i++)
if (current[i] != snapshot[i] && eq(e, current[i]))
return false;
if (indexOf(e, current, common, len) >= 0)
return false;
}
// 復(fù)制原件,修改復(fù)印件,之后復(fù)印件變成原件
Object[] newElements = Arrays.copyOf(current, len + 1);
newElements[len] = e;
setArray(newElements);
return true;
} finally {lock.unlock();
}
}
測(cè)試代碼:
import java.util.Collections;
import java.util.HashSet;
import java.util.Set;
import java.util.UUID;
import java.util.concurrent.CopyOnWriteArraySet;
public class SetUnsefertyTest {public static void main(String[] args) {// Setset = new HashSet<>();
// Setset = Collections.synchronizedSet(new HashSet<>()) ;
Setset =new CopyOnWriteArraySet<>();
for (int i = 1; i< 100; i++) {new Thread(() ->{// 寫(xiě)入
set.add(UUID.randomUUID().toString().substring(0, 8));
// 讀出
System.out.println(set);
}, String.valueOf(i)).start();
}
}
}
你是否還在尋找穩(wěn)定的海外服務(wù)器提供商?創(chuàng)新互聯(lián)www.cdcxhl.cn海外機(jī)房具備T級(jí)流量清洗系統(tǒng)配攻擊溯源,準(zhǔn)確流量調(diào)度確保服務(wù)器高可用性,企業(yè)級(jí)服務(wù)器適合批量采購(gòu),新人活動(dòng)首月15元起,快前往官網(wǎng)查看詳情吧