Stream.Collect方法中的组合器在Java8中是如何工作的？

Question

public static void main(String[] args) {
        List<String> list2 = Arrays.asList("adf", "bcd", "abc", "hgr", "jyt", "edr", "biu");

String collect = list2.stream().collect(String::new, (res, elem) -> {
              res=res.concat(" ").concat(elem);
//            System.out.printf("res=%s, elem=%s\n", res.isEmpty(), elem);

        }, (res1, res2) -> {
            System.out.printf("res1=%s, res2=%s\n", res1, res2);            
        });
        System.out.println("collect=" + collect);
}

如果我使用ParallelStream()，但RES1和RES2两个参数等于supplierString::new，它就会运行。

如何使组合器在collect方法中工作？

Answer 1

首先，没有必要在非并行流中执行合并器，因为没有什么要合并的。

其次，问题源于使用string::new和string.concat。累加器应该通过结合第二个参数来修改第一个参数，但是由于Java中的字符串是不可变的，所以代码不会产生任何结果。

          res=res.concat(" ").concat(elem);

将创建一个新字符串，然后将其丢弃。您希望使用StringBuilder，以便保留中间结果：

public static void main(String[] args) {
    List<String> list2 = Arrays.asList("adf", "bcd", "abc", "hgr", "jyt", "edr", "biu");

    String collect = list2.stream().collect(StringBuilder::new, (res, elem) -> {
        res.append(" ").append(elem);
    }, (res1, res2) -> {
        res1.append(res2.toString());
        System.out.printf("res1=%s, res2=%s\n", res1, res2);
    }).toString();
    System.out.println("collect=" + collect);
}