首頁(yè)常見(jiàn)問(wèn)題正文

Java有線程安全的set嗎?

更新時(shí)間:2023-05-30 來(lái)源:黑馬程序員 瀏覽量:

IT培訓(xùn)班

  在Java中,有線程安全的Set實(shí)現(xiàn)。一個(gè)常用的線程安全的Set實(shí)現(xiàn)是ConcurrentSkipListSetConcurrentSkipListSet是一個(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)。

分享到:
在線咨詢 我要報(bào)名
和我們?cè)诰€交談!