java stream api 没有内置的 builder 模式，但可以通过实现 streamsupport.stream(spliterator, boolean) 配合自定义 spliterator 来构建。具体做法是定义一个支持 add() 方法的类，内部维护数据集合，在 build() 时返回基于该集合的流对象。这样既能享受 builder 的链式调用便利，又能获得 stream 的惰性求值特性。
如何设计支持 add 操作的流构建器
核心在于封装数据源并提供添加接口。创建一个泛型类 StreamBuilder<t></t>，使用 ArrayList 存储元素。提供 add(T item) 方法用于填充数据，并返回自身以支持链式调用。当需要获取流时，调用 build() 方法，该方法将当前列表转换为标准 Stream。这种设计简单直接，适用于内存中数据的流式处理场景。
import java.util.*;
import java.util.stream.Stream;
public class StreamBuilder<T> {
private final List<T> items = new ArrayList<>();
public StreamBuilder<T> add(T item) {
if (item != null) {
items.add(item);
}
return this;
}
public Stream<T> build() {
return items.stream();
}
public static void main(String[] args) {
StreamBuilder<String> builder = new StreamBuilder<>();
builder.add("Hello")
.add("World")
.add("Java");
builder.build()
.filter(s -> s.length() > 4)
.forEach(System.out::println);
}
}运行上述代码，预期输出为：
Hello
World
注意：空值会被忽略，不会加入流中。过滤条件 s.length() > 4 排除了 "Java"（长度为4），因此只打印前两个字符串。
立即学习“Java免费学习笔记（深入）”；
如何处理流构建过程中的异常与状态
在实际使用中，可能需要对添加过程进行校验或处理并发问题。可以在 add 方法中加入逻辑判断，例如检查重复元素或触发特定事件。若需支持线程安全，可将内部 List 替换为 CopyOnWriteArrayList 或使用同步块。此外，build() 后流只能消费一次，再次调用会抛出 IllegalStateException，需在文档中明确说明这一限制。
import java.util.*;
import java.util.stream.Stream;
public class SafeStreamBuilder<T> {
private final List<T> items = Collections.synchronizedList(new ArrayList<>());
private boolean built = false;
public synchronized SafeStreamBuilder<T> add(T item) {
if (built) throw new IllegalStateException("Stream already built");
if (item == null) throw new IllegalArgumentException("Item cannot be null");
items.add(item);
return this;
}
public synchronized Stream<T> build() {
if (built) throw new IllegalStateException("Stream can only be built once");
built = true;
return items.stream();
}
public static void main(String[] args) {
SafeStreamBuilder<Integer> builder = new SafeStreamBuilder<>();
builder.add(1).add(2).add(3);
try {
builder.add(4); // 这将抛出异常
} catch (IllegalStateException e) {
System.out.println(e.getMessage());
}
builder.build().forEach(System.out::print);
}
}运行结果：
Stream already built
123
此版本增加了状态锁和空值检查，确保构建过程的健壮性。一旦调用 build()，后续 add() 操作将被禁止，防止流被意外修改。
基于输入为空时的流行为表现
当向 StreamBuilder 添加零个元素时，build() 返回的是一个空的 Stream。此时执行终端操作如 collect() 会返回空集合，forEach() 不执行任何动作，findFirst() 返回 Optional.empty()。这是 Java Stream 的标准行为，无需特殊处理。开发者应意识到空流依然有效，可继续参与链式操作，不会导致程序崩溃。
