使用 Streams 替换循环

Question

我有以下代码：

boolean found = false;
for (Commit commit : commits.values()) {
    if (commit.getLogMessage().compareTo(commitMessageToSearch) == 0) {
        System.out.println(commit.getSha());
        found = true;
    }
}
if (!found) {
    System.out.println("aksdhlkasj");
}

有没有办法用Java中的流或其他任何东西简洁地编写这个

Answer 1

以下选项可用：

1. 使用StreamEx库（maven repo）及其准中间操作StreamEx::ifEmpty：

import one.util.streamex.StreamEx;
// ...
String msgSearch = "commit message";
StreamEx.of(commits.values())
        .filter(c -> c.getLogMessage().compareTo(msgSearch) == 0)
        .ifEmpty("no commit message found: " + msgSearch)
        .map(Commit::getSha)
        .forEach(System.out::println);

• 另外：非常简洁干净，单次运行
• 减号：使用第 3 方库

---

1. 使用短路匹配检查流的内容没有多余的收集到一个列表中只是为了检查它是否为空

if (commits.values().stream()
    .map(Commit::getLogMessage) // equals should be equivalent to compareTo == 0
    .anyMatch(msgSearch::equals)
) {
    commits.values().stream()
        .filter(c -> c.getLogMessage().compareTo(msgSearch) == 0)
        .map(Commit::getSha)
        .forEach(System.out::println);
} else {
    System.out.println("no commit message found: " + msgSearch);
}

• 另外：使用标准 API（无第三方），没有副作用
• 缺点：过于冗长，在最坏的情况下（最后是匹配元素的长列表）流的双重迭代

---

1. 有效地使用流中的最终变量及其设置作为副作用。

免责声明：有状态流的使用和副作用是not recommended in general：

最好的方法是避免有状态的行为参数完全流式操作...
通常不鼓励对流操作的行为参数产生副作用，因为它们通常会导致无意中违反无状态要求以及其他线程安全隐患。
少数流操作，例如forEach() 和peek()，只能通过副作用操作；这些应该小心使用

因此，如果 AtomicBoolean 被仔细选择为 found 标志的布尔值的线程安全和快速容器，仅从流内部设置为 true (永不重置），可以提供以下解决方案并降低安全和性能风险：

// effectively final and thread-safe container boolean
AtomicBoolean found = new AtomicBoolean(); 

commits.values().stream()
    .filter(c -> c.getLogMessage().compareTo(commitMessageToSearch) == 0)
    .map(Commit::getSha)
    .forEach(sha -> {
        found.set(true); 
        System.out.println(sha);
    });

if (!found.get()) {
    System.out.println("none found");
}

• 另外：使用标准 API（无第三方库），单次运行，无冗余收集
• 减号：使用副作用，纯粹主义者不鼓励，只是模仿 for-each 循环

Answer 2

如果您想打印出所有的出现并打印一些字符串，以防万一，没有找到项目，恐怕除了收集所有相关的sha之外别无他法将值放入列表并使用 Optional 检查其是否为空：

commits.values()
       .stream()
       .filter(commit -> commit.getLogMessage().compareTo(commitMessageToSearch) == 0)
       .map(Commit::getSha)
       .peek(System.out::println)
       .collect(Collectors.collectingAndThen(Collectors.toList(), Optional::of))
       .filter(List::isEmpty)
       .ifPresent(emptyList -> System.out.println("aksdhlkasj"));

虽然中间输出Optional<List<?>>有违常识，但它有助于使用Optinal进行进一步处理，并轻松处理列表为空的情况。

不过，我认为这种形式更具可读性：

List<String> shaList = commits.values()
        .stream()
        .filter(commit -> commit.getLogMessage().compareTo(commitMessageToSearch) == 0)
        .map(Commit::getSha)
        .peek(System.out::println)
        .collect(Collectors.toList());
        
if (shaList.isEmpty()) {
    System.out.println("aksdhlkasj");
}

Answer 3

您可以将Stream#filter 与Stream#findFirst 一起使用。

System.out.println(commits.values().stream()
    .filter(commit -> commit.getLogMessage().compareTo(commitMessageToSearch) == 0)
    .findFirst().map(Commit::getSha).orElse("aksdhlkasj"));