threadSafeUniqueNumbers = ConcurrentHashM" />

精品国产人成在线_亚洲高清无码在线观看_国产在线视频国产永久2021_国产AV综合第一页一个的一区免费影院黑人_最近中文字幕MV高清在线视频

0
  • 聊天消息
  • 系統消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發帖/加入社區
會員中心
創作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

不同創建線程安全Set的方式

科技綠洲 ? 來源:了不起 ? 作者:了不起 ? 2023-09-25 14:20 ? 次閱讀

線程安全的問題,真的算是老生常談了。這幾天看到一個 HashSet 線程安全的騷操作,在這里分享給大家。 在本文中,我們將分享如何構造線程安全的HashSet的幾種方法。

使用ConcurrentHashMap工廠方法構造線程安全的HashSet

首先, 我們來看看_ConcurrentHashMap_暴露出來的靜態方法 -- newKeySet()。此方法返回一個Set的實例,等同于實現了 java.util.Set 接口,而且能夠使用Set的一些常用操作,比如 add(), contains() 等。

舉個例子:

Set< Integer > threadSafeUniqueNumbers = ConcurrentHashMap.newKeySet();
threadSafeUniqueNumbers.add(23);
threadSafeUniqueNumbers.add(45);

這里返回的Set,其實有點類似于 HashSet,因為兩者都是基于Hash算法實現的,另外線程同步邏輯帶來的額外開銷也很小,因為它最終還是 ConcurrentHashMap 的一部分。

不過,這個只能在 Java 8 以上版本才可以使用,我想大部分公司應該至少 Java 8 了吧。直接拿來用就行。

現在,我們已經了解了可以用 ConcurrentHashMap#newKeySet()構建類似于線程安全的HashSet,在 ConcurrentHashMap 其實被定義為 KeySetView。ConcurrentHashMap 其實還有兩個實例方法可以用于構建 KeySetView, 一個是 keySet() 另外一個就是keySet(defaultValue), 我這里就簡寫一下了, 大家可以在IDE中直接打出來看看。

這兩個方法都可以創建KeySetView的實例,KeySetView 與 Map 是一個連接的關系。 我們每次向Map中添加新的鍵值對的時候,Set中的數據也在相應的添加,我們通過幾個例子來看看這兩種方法有哪些區別。

KeySet() 方法

keySet() 方法 和 keySet(defaultValue) ,最大的區別就是不能直接往Set中添加數據。直接添加的話,會拋出 UnsupportedOperationException 異常,源碼中的定義如下。

public KeySetView< K,V > keySet() {
    KeySetView< K,V > ks;
    if ((ks = keySet) != null) return ks;
    return keySet = new KeySetView< K,V >(this, null);
}
// add
public boolean add(K e) {
    V v;
    if ((v = value) == null)
        throw new UnsupportedOperationException();
    return map.putVal(e, v, true) == null;
}

所以我們只能通過如下的方式使用。

ConcurrentHashMap< Integer,String > numbersMap = new ConcurrentHashMap<  >();
Set< Integer > numbersSet = numbersMap.keySet();

numbersMap.put(1, "One");
numbersMap.put(2, "Two");
numbersMap.put(3, "Three");

System.out.println("Map before remove: "+ numbersMap);
System.out.println("Set before remove: "+ numbersSet);

numbersSet.remove(2);

System.out.println("Set after remove: "+ numbersSet);
System.out.println("Map after remove: "+ numbersMap);

輸出結果如下。

Map before remove: {1=One, 2=Two, 3=Three}
Set before remove: [1, 2, 3]

Set after remove: [1, 3]
Map after remove: {1=One, 3=Three}

KeySet(defaultValue) 方法

keySet(defaultValue) ,由于有設置默認的value,可以在添加的時候不會報錯,JDK 源碼縱定義如下:

public KeySetView< K,V > keySet(V mappedValue) {
    if (mappedValue == null)
        throw new NullPointerException();
    return new KeySetView< K,V >(this, mappedValue);
}

所以我們可以通過如下的方式使用。

ConcurrentHashMap< Integer,String > numbersMap = new ConcurrentHashMap<  >();
Set< Integer > numbersSet = numbersMap.keySet("SET-ENTRY");

numbersMap.put(1, "One");
numbersMap.put(2, "Two");
numbersMap.put(3, "Three");

System.out.println("Map before add: "+ numbersMap);
System.out.println("Set before add: "+ numbersSet);

numbersSet.addAll(asList(4,5));

System.out.println("Map after add: "+ numbersMap);
System.out.println("Set after add: "+ numbersSet);

輸出結果如下:

Map before add: {1=One, 2=Two, 3=Three}
Set before add: [1, 2, 3]
Map after add: {1=One, 2=Two, 3=Three, 4=SET-ENTRY, 5=SET-ENTRY}
Set after add: [1, 2, 3, 4, 5]

使用Collections的來創建線程安全的 Set

java.util.Collections 中有一個線程同步的方法可以用于創建,示例代碼如下。

Set< Integer > syncNumbers = Collections.synchronizedSet(new HashSet<  >());
syncNumbers.add(1);

這個方法的性能并沒有ConcurrentHashMap的那個效率高,由于使用了同步鎖,增加了一些額外的開銷。

使用CopyOnWriteArraySet構建線程安全的 Set

用CopyOnWriteArraySet 創建線程安全的 set 也是非常簡單的。示例代碼如下

Set< Integer > copyOnArraySet = new CopyOnWriteArraySet<  >();
copyOnArraySet.add(1);

這個方法從性能的角度上來看,也不是很理想,CopyOnWriteArraySet 背后的實現是CopyOnWriteArrayList, 最終使用了數組來存儲數據,也就意味著 contains() 或者 remove() 操作,具有 O(n) 的復雜度,而使用HashMap 復雜度為 O(1) 。

建議使用此實現時,設置大小通常保持較小,只讀操作占大多數。

總結

在本文中,我們看到了不同的創建線程安全的Set的方式,也比較了他們之間的差異性。 所以大家以后使用的時候,可以考慮使用ConcurrentHashMap創建的Set。

聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。 舉報投訴
  • 接口
    +關注

    關注

    33

    文章

    8526

    瀏覽量

    150862
  • 數據
    +關注

    關注

    8

    文章

    6909

    瀏覽量

    88849
  • SET
    SET
    +關注

    關注

    0

    文章

    17

    瀏覽量

    7937
  • 線程
    +關注

    關注

    0

    文章

    504

    瀏覽量

    19653
  • Hash算法
    +關注

    關注

    0

    文章

    43

    瀏覽量

    7380
收藏 人收藏

    評論

    相關推薦

    Linux下的線程安全是什么

    Linux下的線程安全原文結構有點亂線程安全:多個執行流對臨界資源進行爭搶訪問,而不會造成數據二義性和邏輯混亂,成這段代碼的過程是線程
    發表于 07-01 13:34

    什么是線程安全?如何去實現線程安全

    什么是線程安全?如何去實現線程安全?互斥實現的技術是什么?有哪些注意事項?同步實現的技術是什么?其操作流程有哪些?
    發表于 07-23 09:57

    初學RT-thread線程動態創建

    RT-thread初學線程動態創建線程靜態創建線程鉤子函數定時器獲取系統時間動態創建定時器靜態
    發表于 02-24 07:32

    在RT-Thread系統中創建線程有哪幾種方式

    概述創建線程三要素:1.線程棧2.線程控制塊3.線程主體函數在RTT中線程
    發表于 05-07 14:14

    線程和進程的區別和聯系,線程和進程通信方式

    摘要:進程和線程都是計算里的兩項執行活動,各有特色和優勢。下面就來介紹線程和進程之間的區別聯系以及通信方式
    發表于 12-08 14:12 ?1.2w次閱讀

    線程的實現方式,四線程和八線程的區別介紹

    摘要:線程是程序執行流的最小單元。四線程和八線程線程的兩種表現形式,下面來看看它們之間的區別以及線程的實現
    發表于 12-08 14:31 ?1.2w次閱讀

    linux下多線程創建與等待詳解

    的時候,線程就立刻被結束。而同步終結則不會立刻終結,它會繼續運行,直到到達下一個結束點(cancellation point)。當一個線程被按照默認的創建方式
    發表于 04-02 14:48 ?316次閱讀

    python創建線程的兩種方法

    1. 用函數創建線程 在Python3中,Python提供了一個內置模塊 threading.Thread ,可以很方便地讓我們創建線程。 threading.Thread() 一
    的頭像 發表于 03-15 16:47 ?5276次閱讀

    python創建線程池的兩種方法

    在使用多線程處理任務時也不是線程越多越好,由于在切換線程的時候,需要切換上下文環境,依然會造成cpu的大量開銷。為解決這個問題,線程池的概念被提出來了。預先
    的頭像 發表于 03-16 16:15 ?5960次閱讀

    如何理解線程安全

    本次分享線程安全的基礎知識。
    的頭像 發表于 05-08 15:03 ?837次閱讀
    如何理解<b class='flag-5'>線程</b><b class='flag-5'>安全</b>?

    什么是線程安全?如何理解線程安全

    在多線程編程中,線程安全是必須要考慮的因素。
    的頭像 發表于 05-30 14:33 ?2040次閱讀
    什么是<b class='flag-5'>線程</b><b class='flag-5'>安全</b>?如何理解<b class='flag-5'>線程</b><b class='flag-5'>安全</b>?

    線程安全怎么辦

    線程安全一直是多線程開發中需要注意的地方,可以說,并發安全保證了所有的數據都安全。 1 線程
    的頭像 發表于 10-10 15:00 ?345次閱讀
    <b class='flag-5'>線程</b><b class='flag-5'>安全</b>怎么辦

    線程池的創建方式有幾種

    的開銷。線程池的創建方式有多種,下面將詳細介紹幾種常用的線程創建方式。 手動
    的頭像 發表于 12-04 16:52 ?829次閱讀

    redis多線程還能保證線程安全

    Redis是一種使用C語言編寫的高性能鍵值存儲系統,它是單線程的,因為使用了多路復用的方式來處理并發請求。這樣的實現方式帶來了很好的性能,但同時也引發了一些線程
    的頭像 發表于 12-05 10:28 ?1711次閱讀

    java實現多線程的幾種方式

    的CompletableFuture 一、繼承Thread類 繼承Thread類是實現多線程的最基本方式,只需創建一個類并繼承Thread類,重寫run()方法即可。 ``
    的頭像 發表于 03-14 16:55 ?583次閱讀