Stream API와 병렬 처리

Stream<Order> s = orders.stream().filter(Order::paid);
long count = s.count();
List<Order> list = s.toList();   // IllegalStateException: stream has already been operated upon or closed

✅
List<Order> paid = orders.stream().filter(Order::paid).toList();   // 결과를 컬렉션으로 받아 재사용
long count = paid.size();
// 또는 Supplier<Stream<Order>> s = () -> orders.stream().filter(Order::paid); 로 매번 새로 생성

Map<String, Order> byCustomer = orders.stream().collect(toMap(Order::customer, o -> o));
// 같은 고객이 두 번 나오면 IllegalStateException: Duplicate key

✅
Map<String, Order> latest = orders.stream()
    .collect(toMap(Order::customer, o -> o, (a, b) -> a.date().isAfter(b.date()) ? a : b));
// 또는 groupingBy 로 List 로 받기

List<String> ids = new ArrayList<>();
orders.stream().filter(Order::paid).forEach(o -> ids.add(o.id()));   // 순차에선 되지만 parallel 붙이면 깨짐

✅
List<String> ids = orders.stream().filter(Order::paid).map(Order::id).toList();

long errors = Files.lines(path).filter(l -> l.contains("ERROR")).count();   // 파일 핸들 누수

✅
try (Stream<String> lines = Files.lines(path)) {
    long errors = lines.filter(l -> l.contains("ERROR")).count();
}

List<String> names = users.parallelStream().map(User::name).toList();   // 요소 50개, 작업은 getter 하나

✅
List<String> names = users.stream().map(User::name).toList();
// 병렬이 필요하면: 데이터 수만 개 이상 + 요소당 계산 무거움 + I/O 없음 + 벤치마크로 확인

orders.stream().peek(o -> o.markProcessed()).count();   // JDK 9+ 에서 count 가 크기를 바로 알면 peek 이 실행 안 될 수 있음

✅
orders.forEach(Order::markProcessed);

Order biggest = orders.stream().max(comparingLong(Order::amount)).get();   // 빈 리스트면 NoSuchElementException

✅
Order biggest = orders.stream().max(comparingLong(Order::amount))
    .orElseThrow(() -> new IllegalStateException("주문 없음"));