java 線程中創(chuàng)建線程

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

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

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

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

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

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

以下是在Java 8中創(chuàng)建ConcurrentHashSet的代碼示例：

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

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

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

這是在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一起執(zhí)行其他Set操作，例如addAll（），remove（），removeAll（），retainAll（），contains（）。 它也是線程安全的，因此可以在多線程Java應(yīng)用程序中使用。 您可以了解有關(guān)真正不耐煩的Java SE 8上基于集合的操作的更多信息。

Java程序，用于從ConcurrentHashMAp創(chuàng)建ConcurrentHashSet。

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

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創(chuàng)建線程安全Set的唯一方法。 甚至在Java 8之前，都有一個名為CopyOnWriteArraySet的類，該類允許您在Java中創(chuàng)建線程安全的集。 它類似于CopyOnWriteArrayList，并且僅適用于集合大小小的應(yīng)用程序，并且您只讀取唯一的操作，因為它每次寫入時都會將Set中的所有元素復(fù)制到新的Set中。 有關(guān)真正不耐煩的信息 ，請參閱Java SE 8，以了解有關(guān)Java 8中并發(fā)集合的更多信息。

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

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

2.這是線程安全的。

3.可變操作（添加，設(shè)置，刪除等）很昂貴，因為它們通常需要復(fù)制整個基礎(chǔ)數(shù)組。

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

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

6.迭代器在構(gòu)造迭代器時依賴于數(shù)組的不變快照。

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

進(jìn)一步閱讀

• 使用Lambda表達(dá)式從Java 8中的集合到流
• Java 8中用于數(shù)據(jù)處理的流，收集器和可選項
• Java 8實戰(zhàn)

相關(guān)文章：

如何用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 線程中創(chuàng)建線程

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。