更新時(shí)間:2023-05-30 來(lái)源:黑馬程序員 瀏覽量:
在Java中,有線程安全的Set實(shí)現(xiàn)。一個(gè)常用的線程安全的Set實(shí)現(xiàn)是ConcurrentSkipListSet。ConcurrentSkipListSet是一個(gè)有序的集合,基于跳表(SkipList)的數(shù)據(jù)結(jié)構(gòu)實(shí)現(xiàn)。它提供了線程安全的操作,并且具有較好的性能。
接下來(lái)筆者用一段簡(jiǎn)單的Java代碼,來(lái)展示下如何使用ConcurrentSkipListSet:
import java.util.Set; import java.util.concurrent.ConcurrentSkipListSet; public class ThreadSafeSetExample { public static void main(String[] args) { // 創(chuàng)建一個(gè)線程安全的Set實(shí)例 Set<Integer> threadSafeSet = new ConcurrentSkipListSet<>(); // 創(chuàng)建并啟動(dòng)多個(gè)線程進(jìn)行Set操作 Thread thread1 = new Thread(() -> { for (int i = 0; i < 1000; i++) { threadSafeSet.add(i); } }); Thread thread2 = new Thread(() -> { for (int i = 1000; i < 2000; i++) { threadSafeSet.add(i); } }); thread1.start(); thread2.start(); try { // 等待兩個(gè)線程執(zhí)行完畢 thread1.join(); thread2.join(); } catch (InterruptedException e) { e.printStackTrace(); } // 打印Set中的元素?cái)?shù)量 System.out.println("Set size: " + threadSafeSet.size()); } }
在這個(gè)例子中,我們創(chuàng)建了一個(gè)ConcurrentSkipListSet實(shí)例,并啟動(dòng)了兩個(gè)線程分別向Set中添加元素。由于ConcurrentSkipListSet是線程安全的,多個(gè)線程可以同時(shí)執(zhí)行添加操作而不會(huì)出現(xiàn)數(shù)據(jù)競(jìng)爭(zhēng)或者錯(cuò)誤的結(jié)果。最后,我們打印Set的大小,可以看到結(jié)果是2000,說(shuō)明兩個(gè)線程成功地向Set中添加了元素。
請(qǐng)注意,ConcurrentSkipListSet是有序的,它根據(jù)元素的自然順序進(jìn)行排序。如果你需要一個(gè)無(wú)序的線程安全Set實(shí)現(xiàn),可以考慮使用ConcurrentHashSet,它是ConcurrentHashMap的一個(gè)封裝,使用了哈希表作為底層數(shù)據(jù)結(jié)構(gòu)。