要在Java流中創(chuàng)建一個自定義的收集器，請與供應(yīng)商，累加器，組合儀和完成器一起使用collector.of（）。 1。供應(yīng)商初始化容器。 2。累加器向其添加元素。 3。組合器合并容器，對平行流至關(guān)重要。 4.修訂程序?qū)⒔Y(jié)果轉(zhuǎn)換為所需類型。確保組合儀在并行性方面正常工作。當(dāng)需要重復(fù)使用或API集成時，請使用自定義收集器，否則更喜歡Reald（）。徹底測試，特別是用于并行使用。

當(dāng)您使用Java流并需要做比Collectors.toList()或Collectors.toSet()提供更具體的事情時，創(chuàng)建自定義收集器是必經(jīng)之路。密鑰是正確實現(xiàn)了Collector接口，同時了解每個零件如何適合流管線。

在編寫自定義收藏家之前，您需要什么

在撰寫自己的收藏家之前，請確保您了解：

• Java流如何工作，尤其是終端操作。
• 可變和不變減少之間的差異。
• 收藏家定義了四個操作：供應(yīng)商，累加器，組合和完成者。

您還需要在啟動之前導(dǎo)入java.util.stream.Collector和相關(guān)類。

一個很好的示例用例可能是將數(shù)據(jù)收集到不可變的自定義容器中，或以特殊格式的匯總結(jié)果。

逐步實現(xiàn)收集器接口

Java提供了一種Collector.of()方法，該方法使定義所有必要的部分更容易，而無需編寫實現(xiàn)Collector完整類。

這是您可以結(jié)構(gòu)它的方式：

 collector <t，a，r> collector = collector.of（
    （） - >新Intermediatecontainer（），//供應(yīng)商
    （容器，元素） - > container.add（element），//累加器
    （container1，container2） - > container1.merge（container2），// combiner
    容器 - > container.getResult（）//完成程序
）；

讓我們分解這些部分：

• 供應(yīng)商：返回一個新的結(jié)果容器。這是您每次減少的重新開始的地方。
• 累加器：將元素從流中添加到容器中。
• 組合機：合并兩個容器 - 這對于并行流很重要。
• 完成程序：將最終中間結(jié)果轉(zhuǎn)換為所需的輸出類型。

除非您知道收集器只能順序使用，否則請確保在并行方案中正確工作。

示例：收集到自定義不變列表

假設(shè)您想將元素收集到自定義不可變的列表包裝中。這是您的方式：

公共類Myimmutablist <t> {
    私人最終列表<t>列表;

    公共myimmutablist（列表<t>列表）{
        this.list = collections.unmodifiablestist（new ArrayList <>（list））;
    }

    public static <t> collector <t，？，myimmutablelist <t >> tomyimmutablist（）{
        返回collector.of（
            arraylist :: new，
            列表:: add，
            （List1，List2） - > {
                List1.addall（List2）;
                返回列表1;
            }，，
            myimmutablelist :: new
        ）；
    }
}

那么您可以這樣使用：

 myimmutablist <string> result = stream.collect（myimmutablist.tomyimmutablist（））;

這種模式為您提供了靈活性，并保持流管道清潔。

要注意的一件事：如果您忘記正確處理組合儀，則收集器可能無法在平行流中正確行為。

何時使用自定義收藏家與定期減少

自定義收藏家是最好的：

• 您會發(fā)現(xiàn)自己在多個地方重復(fù)相同的減少邏輯。
• 您需要與期望Collector現(xiàn)有API集成。
• 您想抽象清潔器代碼的復(fù)雜集合邏輯。

另一方面，如果是一次性操作，則只需使用reduce()可能更簡單，更可讀即可。

所以問問自己：我會重復(fù)使用嗎？如果是，請建立收藏家。如果否，請堅持減少或簡單的可突變?nèi)萜鳌?/p>

基本上就是這樣。一旦將模式放下，它就不會過于復(fù)雜，但是有足夠的活動部件應(yīng)徹底測試，尤其是如果您打算在平行流中使用收集器。

以上是如何為Java流創(chuàng)建自定義收集器？的詳細內(nèi)容。更多信息請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！