Java 8 修改流元素

Question

我想用 Java 8 编写纯函数，它将一个集合作为参数，对该集合的每个对象应用一些更改，并在更新后返回一个新集合。我想遵循 FP 原则，所以我不想更新/修改作为参数传递的集合。

有没有什么方法可以用 Stream API 做到这一点，而无需先创建原始集合的副本（然后使用 forEach 或“正常”for 循环）？

下面的示例对象，假设我想将文本附加到对象属性之一：

public class SampleDTO {
    private String text;
}

所以我想做类似于下面的事情，但不修改集合。假设“列表”是List<SampleDTO>。

list.forEach(s -> {
    s.setText(s.getText()+"xxx");
});

Answer 1

您必须有一些方法/构造函数来生成现有SampleDTO 实例的副本，例如复制构造函数。

然后你可以将map每个原来的SampleDTO实例转化为一个新的SampleDTO实例，并将collect它们转化为一个新的List：

List<SampleDTO> output = 
    list.stream()
        .map(s-> {
                     SampleDTO n = new SampleDTO(s); // create new instance
                     n.setText(n.getText()+"xxx"); // mutate its state
                     return n; // return mutated instance
                 })
       .collect(Collectors.toList());

Answer 2

为了让这种方式更优雅，我建议在课堂上创建一个Method。

 public class SampleDTO {
 private String text;
public String getText() {
    return text;
}

public void setText(String text) {
    this.text = text;
}

public SampleDTO(String text) {
    this.text = text;
}

public SampleDTO getSampleDTO() {
    this.setText(getText()+"xxx");
    return this;
}
    }

并像这样添加它：

List<SampleDTO> output =list.stream().map(SampleDTO::getSampleDTO).collect(Collectors.toList();

Answer 3

流与字符串一样是不可变的，因此您无法绕过需要创建新的流/列表/数组

话虽如此，您可以使用 .Collect() 来返回一个新的集合发布更改所以

List<Integer> result = inList.stream().map().Collect()

Answer 4

我认为将原始列表流式传输到新的修改列表或其他任何需要的列表中会更好，尤其是在进行多线程工作时。

可以创建新的列表或地图或您想要的任何其他结构作为流式处理过程的一部分。

流式传输过程完成后，只需将原件换成新件即可。

所有这些都应该发生在一个同步块中。

通过这种方式，您可以获得最大的性能和并行性，用于 reduce 或您正在执行的任何操作，并以原子交换结束。

Answer 5

我认为更简洁、更易读的解决方案是：

List<SampleDTO> unmodifiable = Arrays.asList(new SampleDTO("1"), new SampleDTO("2"));

List<SampleDTO> modified = unmodifiable.stream()
            .map(s -> new SampleDTO(s.getText())) // '.map(SampleDTO::new)' with copy constructor
            .peek(s -> s.setText(s.getText() + "xxx"))
            .collect(Collectors.toList());

或者，如果您有 SampleDTO 的复制构造函数，您可以将 map 函数替换为 .map(SampleDTO::new)。

peek 函数将对 Stream 的元素提供操作，而不改变 Stream 的结果类型。