当在Iterable上使用外部迭代时，我们使用break或return from enhanced for-each循环，如下:
for (SomeObject obj : someObjects) {
if (some_condition_met) {
break; // or return obj
}
}
如何在Java 8 lambda表达式中使用内部迭代中断或返回:
someObjects.forEach(obj -> {
//what to do here?
})
当前回答
如果你需要这个，你不应该使用forEach，而是在流上可用的其他方法之一;哪一个，取决于你的目标是什么。
例如，如果这个循环的目标是找到与某个谓词匹配的第一个元素:
Optional<SomeObject> result =
someObjects.stream().filter(obj -> some_condition_met).findFirst();
(注意:这不会遍历整个集合，因为流是惰性计算的——它将在第一个匹配条件的对象处停止)。
如果你只想知道集合中是否有一个元素的条件为真，你可以使用anyMatch:
boolean result = someObjects.stream().anyMatch(obj -> some_condition_met);
其他回答
我所取得的成就
private void doSomething() {
List<Action> actions = actionRepository.findAll();
boolean actionHasFormFields = actions.stream().anyMatch(actionHasMyFieldsPredicate());
if (actionHasFormFields){
context.addError(someError);
}
}
}
private Predicate<Action> actionHasMyFieldsPredicate(){
return action -> action.getMyField1() != null;
}
lambda中的return等于for-each中的continue，但不等同于break。你可以直接返回继续:
someObjects.forEach(obj -> {
if (some_condition_met) {
return;
}
})
更新到Java 9+与takeWhile:
MutableBoolean ongoing = MutableBoolean.of(true);
someobjects.stream()...takeWhile(t -> ongoing.value()).forEach(t -> {
// doing something.
if (...) { // want to break;
ongoing.setFalse();
}
});
public static void main(String[] args) {
List<String> list = Arrays.asList("one", "two", "three", "seven", "nine");
AtomicBoolean yes = new AtomicBoolean(true);
list.stream().takeWhile(value -> yes.get()).forEach(value -> {
System.out.println("prior cond" + value);
if (value.equals("two")) {
System.out.println(value);
yes.set(false);
}
});
//System.out.println("Hello World");
}
您可以使用java8 + rxjava。
//import java.util.stream.IntStream;
//import rx.Observable;
IntStream intStream = IntStream.range(1,10000000);
Observable.from(() -> intStream.iterator())
.takeWhile(n -> n < 10)
.forEach(n-> System.out.println(n));
