在JDK 8之前，還沒有辦法在Java中創建大型的線程安全的ConcurrentHashSet。 java.util.concurrent包甚至沒有一個名為ConcurrentHashSet的類，但是從JDK 8開始，您可以使用新添加的keySet（默認值）和newKeySet（）方法來創建由ConcurrentHashMap支持的ConcurrentHashSet。 與戰術解決方案不同，例如將并發哈希映射與偽值一起使用或使用映射的設置視圖，您無法在其中添加新元素。 JDK 8的keySet（defaultValue）和newKeySet（）方法返回的Set是一個合適的集合，您還可以在其中添加新元素以及執行其他set操作，例如contains（），remove（）等。這些方法僅在ConcurrentHashMap類中可用，而在ConcurrentMap接口中不可用，因此您需要使用ConcurrentHashMap變量來保存引用，或者需要使用類型轉換來強制轉換存儲在ConcurrentMAp變量中的ConcurrentHashMap對象。

Java并發API具有流行的Collection類的并發版本，例如ArrayList的CopyOnArrayList，HashMap的ConcurrentHahsMap和HashSet的CopyOnWriteArraySet，但是Java中沒有類似ConcurrentHashSet的東西。 即使CopyOnWriteArraySet是線程安全的，也不適合需要大型線程安全集的應用程序。 它僅用于集大小較小且只讀操作遠遠超過寫入操作的應用程序。

因此，當您向Java程序員詢問如何在不編寫自己的類的情況下創建ConcurrentHashSet時，許多人會說他們可以將ConcurrentHashMap與虛假值一起使用。 實際上，這也是Java所做的，因為如果您知道HashSet在內部使用具有相同值的HashMap。

但是，這種方法的問題是您有一個地圖并且沒有設置。 您不能使用虛擬值在ConcurrentHashMap上執行設置操作。 當某些方法需要一個集合時，您不能將其傳遞出去，因此它不是很有用。

另一個選擇是，許多Java程序員都會提到您可以通過調用keySet（）方法從ConcurrentHashMap中獲取Set視圖，該方法實際上返回一個Set，您可以在其中執行Set操作并將其傳遞給需要Set的方法。但是這種方法也有其局限性，例如Set由ConcurrentHashMAp支持，并且Map中的任何更改也將反映在Set中。 另一個限制是您不能在此鍵集中添加新元素，否則將引發UnsupportedOperationException。 看到
Java 8 in Action了解更多信息。

這兩個限制現在已成為過去，因為JDK 8添加了newKeySet（）方法，該方法從給定類型（其中值為Boolean.TRUE）返回由ConcurrentHashMap支持的Set。 與從keySet（）方法返回的Set視圖不同，您還可以將新對象添加到此Set中。 該方法也很重載，并且接受初始容量以防止Set的大小調整。

以下是在Java 8中創建ConcurrentHashSet的代碼示例：

ConcurrentHashMap certificationCosts = new ConcurrentHashMap<>(); Set concurrentHashSet = certificationCosts.newKeySet(); concurrentHashSet.add("OCEJWCD"); //OK concurrentHashSet.contains("OCEJWCD"); //OK concurrentHashSet.remove("OCEJWCD"); //OK

順便說一句，這并不是用Java創建并發的，大的，線程安全的Set的唯一方法。 您還可以使用新添加的，重載的keySet（默認值）方法來創建ConcurrentHashSet。 此方法使用給定的任何默認添加默認值（即Collection.add和Collection.addAll（Collection））返回ConcurrentHashMap中鍵的Set視圖。

當然，這只能用于您可以對Set中的所有元素使用相同的值，這在大多數情況下是可以的，因為您實際上并不關心Set中的值。 請記住，HashSet還是一個對所有元素都具有相同值的HashMap，有關更多詳細信息，請參見HashSet在Java內部的工作方式 。

這是在Java 8中使用keySet（mapped value）方法獲取ConcurrentHashSet的示例：

ConcurrentHashMap certificationCosts = new ConcurrentHashMap<>(); Set concurrentHashSet = certificationCosts.keySet(246); concurrentSet.add("Spring enterprise"); // value will be 246 but no error

您還可以與此Set一起執行其他Set操作，例如addAll（），remove（），removeAll（），retainAll（），contains（）。 它也是線程安全的，因此可以在多線程Java應用程序中使用。 您可以了解有關真正不耐煩的Java SE 8上基于集合的操作的更多信息。

Java程序，用于從ConcurrentHashMAp創建ConcurrentHashSet。

這是我們完整的Java程序，它使用在java.util.concurrent.ConcurrentHashMap類上添加的新方法在Java 8中創建大型的線程安全的并發哈希集。

import java.util.Set; import java.util.concurrent.ConcurrentHashMap;/* * Java Program to remove key value pair from Map while * iteration. */ public class Demo {public static void main(String[] args) throws Exception {ConcurrentHashMap certificationCosts = new ConcurrentHashMap<>(); certificationCosts.put("OCAJP", 246); certificationCosts.put("OCPJP", 246); certificationCosts.put("Spring Core", 200); certificationCosts.put("Spring Web", 200); certificationCosts.put("OCMJEA", 300);Set concurrentSet = certificationCosts.keySet();System.out.println("before adding element into concurrent set: " + concurrentSet); // concurrentSet.add("OCEJWCD"); // will throw UnsupportedOperationExcetpion System.out.println("after adding element into concurrent set: " + concurrentSet);// creating concurrent hash set in Java 8 using newKeySet() method Set concurrentHashSet = certificationCosts.newKeySet();concurrentHashSet.add("OCEJWCD"); concurrentHashSet.contains("OCEJWCD"); concurrentHashSet.remove("OCEJWCD"); System.out.println("after adding element into concurrent HashSet: " + concurrentSet);// you can also use keySet(defaultValue) method to add element into Set concurrentSet = certificationCosts.keySet(246); concurrentSet.add("Spring enterprise"); // value will be 246 but no error}}Output before adding an element into the concurrent set: [Spring Web, OCPJP, OCAJP, Spring Core, OCMJEA] after adding an element into the concurrent set: [Spring Web, OCPJP, OCAJP, Spring Core, OCMJEA] after adding an element into concurrent HashSet: [Spring Web, OCPJP, OCAJP, Spring Core, OCMJEA]

您可以看到，如果嘗試將新對象添加到由ConcurrentHashMAp的keySet（）方法返回的Set中，則會拋出UnsupportedOperationExcepiton，如下所示：

線程“ main”中的異常java.lang.UnsupportedOperationException

在java.util.concurrent.ConcurrentHashMap $ KeySetView.add（ConcurrentHashMap.java:4594）在Demo.main（Demo.java:23）

這就是為什么我注釋了該代碼，但是，newKeySet（）和keySet（mapped value）方法返回的Set允許您將新元素添加到Set中，那里沒有錯誤。

順便說一下，這不是用Java創建線程安全Set的唯一方法。 甚至在Java 8之前，都有一個名為CopyOnWriteArraySet的類，該類允許您在Java中創建線程安全集。 它類似于CopyOnWriteArrayList，并且僅適用于集合大小小的應用程序，并且您只讀取唯一的操作，因為它每次寫入時都會將Set中的所有元素復制到新的Set中。 有關真正不耐煩的信息 ，請參閱Java SE 8，以了解有關Java 8中并發集合的更多信息。

以下是CopyOnWriteArraySet的一些重要屬性：

1.它最適合于集大小通常較小的應用，只讀操作遠遠多于可變操作，并且您需要防止遍歷期間線程之間的干擾。

2.這是線程安全的。

3.可變操作（添加，設置，刪除等）非常昂貴，因為它們通常需要復制整個基礎數組。

4.迭代器不支持可變刪除操作。

5.通過迭代器的遍歷速度很快，不會遇到其他線程的干擾。

6.迭代器在構造迭代器時依賴于數組的不變快照。

這就是如何在Java 8中創建ConcurrentHashSet的全部內容。 JDK 8 API不僅具有lambda表達式和流之類的主要功能，而且還具有這些小的更改，這些使您的日常編碼更加容易。 使用newKeySet（）方法在Java中創建ConcurrentHashSet并非易事。 您不需要使用帶有偽造值的集合之類的地圖，也不必使用keySet（）返回的集合視圖的局限性，后者不允許您向集合中添加新元素。

進一步閱讀

• 使用Lambda表達式從Java 8中的集合到流
• Java 8中用于數據處理的流，收集器和可選項
• Java 8實戰

相關文章：

如何用Java 8編寫Comparator？
如何在Java 8中讀取文件？
如何在Java 8中加入String？ 如何在Java 8中比較日期？ 如何在Java 8中格式化日期？ 如何在Java 8中對列表排序？

非常感謝您閱讀本文。 如果您喜歡本教程，請與您的朋友和同事分享。

翻譯自: https://www.javacodegeeks.com/2017/08/create-thread-safe-concurrenthashset-java-8.html

總結

以上是生活随笔為你收集整理的如何在Java 8中创建线程安全的ConcurrentHashSet？的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。