Java 8 流、groupBy 和方法调用

Question

我有以下代码:

ConcurrentMap<String, Zipper> zippers = list.parallelStream()
    .map( f -> {return new Facet( f ) ; } )
    .collect( 
        Collectors.groupingByConcurrent( Facet::getZip,
        Collector.of( Zipper::new, 
                  Zipper::accept, 
                  (a,b)-> {a.combine(b); return a; } )
        )) ;

for ( String key: zippers.keySet() )
{
    zippers.get( key ).zip() ;
}

鉴于我只需要 Zipper 对象来调用它们的 zip() 方法，有没有办法在创建每个对象之后调用此方法作为流的一部分(并立即丢弃这些对象)在对它们调用 zip() 方法之后)而不是首先创建 map ？

Answer 1

您可能需要使用整理器的 4 参数 Collector#of。

请注意f -> {return new Facet(f); } 可以写成 Facet::new

ConcurrentMap<String, Zipper> zippers = list.parallelStream()
    .map(Facet::new)
    .collect( 
        Collectors.groupingByConcurrent(
            Facet::getZip,
            Collector.of( Zipper::new, 
                Zipper::accept, 
                (a,b)-> {a.combine(b); return a; },
                z -> {z.zip(); return z;}
            )
        )
    );