流api简化方法

Question

我正在学习流api，我被流的reduce方法困住了。我有一些细绳，我想把它们凝聚起来。下面是我的代码片段：

Stream<String> data = Stream.of("a", "b", "c", "d", "e", "f");
String col = data.parallel().reduce("dummy",
        (t, u) -> {
            return t + " : " + u;
        },
        (a, b) -> {
            return a + b;
        });
System.out.println(col);
//Output: dummy : adummy : bdummy : cdummy : ddummy : edummy : f
//Expected: dummy : a : b : c : d : e : f

我不想让它们按顺序排列，但至少它们不应该重复“虚拟”字符串。

这会导致奇怪的输出。请帮我找出这里出了什么问题。

Answer 1

上面包含的减少不起作用的原因是“标识值必须是组合器函数的标识。这意味着对于所有u，组合器（标识，u）等于u。”

虚拟值不等于字符串连接的有效标识，因为虚拟值不等于值。用这样的东西替换应该可以：

    public static void main(String args[])
    {
        Stream<String> data = Stream.of("a", "b", "c", "d", "e", "f");
        System.out.println(data.parallel().reduce("", Test::accumulate));
    }

    private static String accumulate(String v1, String v2)
    {
        if(v1.isEmpty()) return v2;
        if(v2.isEmpty()) return v1;
        return v1 +":" + v2;
    }

作为一种选择，假设“虚拟”只是因为减少期望提供初始状态而被包括在内，这样的事情可能对您的目的有用：

data.parallel().reduce((v1, v2) -> v1 +":" + v2).orElse("???");

or

data.parallel().collect(Collectors.joining(":"));

编辑-为什么reduce的行为是这样的？

在同时聚合数据时，需要做出某些假设。例如，流中元素的合并顺序不应影响结果的有效性。为了解决这个问题，在减少操作中可能使用的函数类型有一定的限制。一个限制是：

'标识值必须是组合器函数的标识。这意味着对于所有的u，组合器（identity，u）等于u

因此，至少我们可以说，从功能上讲，没有理由在并行执行时不能将标识传递给所有元素。关于为什么考虑以下内容可能有用：

1. 从计算的角度来看，如果只允许第一个元素与标识组合，这意味着什么
2. 如果我想立即开始处理第二个元素呢

（有关更多详细信息，请参见此答案：https://stackoverflow.com/a/51290673/14294525)

Answer 2

您也可以使用以下不带减少，

Stream<String> data = Stream.of("a", "b", "c", "d", "e", "f");
String output = data.parallel().collect(Collectors.joining(" : ", "dummy : ", ""));