我的确切场景是将数据批量插入数据库,所以我想累积 DOM 对象,然后每 1000 个,刷新它们。
我通过将代码放入累加器中以检测填充度然后刷新来实现它,但这似乎是错误的 - 刷新控制应该来自调用者。
我可以将流转换为 List,然后以迭代方式使用 subList,但这似乎也很笨重。
是否有一种巧妙的方法可以对每 n 个元素采取行动,然后继续处理流,同时只处理一次流?
最佳答案
优雅在旁观者的眼中。如果你不介意在 groupingBy
中使用有状态函数,你可以这样做:
AtomicInteger counter = new AtomicInteger();
stream.collect(groupingBy(x->counter.getAndIncrement()/chunkSize))
.values()
.forEach(database::flushChunk);
这不会比您的原始解决方案赢得任何性能或内存使用点,因为它仍然会在执行任何操作之前实现整个流。
如果您想避免具体化列表,流 API 将无济于事。您将必须获取流的迭代器或拆分器并执行以下操作:
Spliterator<Integer> split = stream.spliterator();
int chunkSize = 1000;
while(true) {
List<Integer> chunk = new ArrayList<>(size);
for (int i = 0; i < chunkSize && split.tryAdvance(chunk::add); i++){};
if (chunk.isEmpty()) break;
database.flushChunk(chunk);
}
关于java - 有没有一种优雅的方式来分块处理流?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27583623/