Java 8中使用Lambdas的计数频率（专用）

Question

我有这样一个字符串列表：“na”，“na”，“na”，“uk”，“uk”。我想计算每个元素的频率，如果现有贴图的值为偶数，那么我将添加1；否则2。

 List<String> streamer=Arrays.asList("na","na","na","uk","uk");
        Map<String,Integer> m=new HashMap<>();
        for(String s:streamer)
        {
            if(m.containsKey(s))
            {
                if(m.get(s)%2==0)
                    m.put(s,m.get(s)+1);
                else
                    m.put(s,m.get(s)+2);
            }
            else
                m.put(s,1);
        }
        System.out.println("CUSTOM Frequency::::"+m); 

现在，我想使用stream和lambdas来实现完全相同的事情。我所能做的就是：

Map<String, Long>map4 = streamer.stream()
                .collect(Collectors.groupingBy(Function.identity(),
                        Collectors.counting())); //How can I get custom counting instead of Collectors.counting()?

Answer 1

除了@Sweeper的答案以获得预期的计数结果外，如果您的问题还暗示了如何自定义收集操作，您可以使用Collector类的（）方法。

https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Collector.html#of（java.util.function.Supplier、java.util.function.BiConsumer、java.util.function.BinaryOperator、java.util.stream.Collector.Characteristics…）

该方法接受供应商、作为双消费者的累加器和作为二进制运算符的组合器。供应商只需提供存储结果的容器，在您的示例中是一个映射

List<String> streamer = Arrays.asList("na", "na", "na", "uk", "uk");
Map<String, Long> map4 = streamer.stream()
        .collect(Collector.of(
                HashMap::new,
                (Map<String, Long> map, String s) -> {
                    if (!map.containsKey(s)) {
                        map.put(s, 1L);
                    } else {
                        map.computeIfPresent(s, (String key, Long val) -> val % 2 != 0 ? val + 2 : val + 1);
                    }
                },
                (Map<String, Long> map1, Map<String, Long> map2) -> {
                    map1.putAll(map2);
                    return map1;
                }
        ));

{na=5, uk=3}

Answer 2

请注意，您的自定义计数方式总是导致计数比正常计数结果少一倍。你基本上把每件事都算为2件事，除了第一件事。唯一的边缘情况是0，其中两种计数方法产生相同的结果，但如果它是0，则无论如何都不会将其放入地图中，因此我们实际上不需要处理它。

我们可以从收集器中计算出所需的结果。counting（）使用收集器，然后使用收集器：

var frequency = streamer.stream().collect(Collectors.groupingBy(Function.identity(),
    Collectors.collectingAndThen(Collectors.counting(),
        normalCount -> normalCount * 2 - 1)
    ));