Tổng kết module — Stream API & Lambda

TL;DR: Module Stream API & Lambda dạy cách xử lý dữ liệu theo functional style trong Java — từ lambda & method reference (building block), stream pipeline lazy (cơ chế cốt lõi), collectors & optional (terminal nâng cao), đến parallel stream & immutability (production concerns). Bài này là recap + self-assessment để kiểm tra xem bạn thực sự nắm trước khi tiếp tục.

Hành trình qua module

Bạn vừa đi qua 10 bài concept + mini-challenge:

1. Lambda & Functional Interface — SAM type, @FunctionalInterface, 4 built-in cốt lõi (Predicate, Function, Consumer, Supplier)
2. Method Reference & invokedynamic — 4 loại method ref, cơ chế invokedynamic bytecode, tại sao không slower than lambda
3. Stream basics — lazy pipeline, intermediate vs terminal, element-by-element, short-circuit
4. map / filter / reduce — 3 op cốt lõi, reduce nontrivial, chaining
5. Stream nâng cao — flatMap, distinct, sorted, takeWhile/dropWhile, peek
6. Optional — NPE-safe chaining, map/flatMap/orElse/orElseThrow
7. Collectors deep — groupingBy, partitioningBy, joining, downstream collector, custom Collector
8. Parallel Stream — ForkJoinPool, khi nào parallel win/lose, thread-safety, Spliterator
9. Immutability & Functional Style — value object, pure function, compose pipeline
10. Mini-challenge Sales Report — tổng hợp toàn bộ

Cheat-sheet

Phân loại operation

Nguồn stream thường dùng

Functional interface mapping

Glossary

Pitfall checklist

Trước khi merge code dùng Stream, kiểm tra từng mục này (xem chi tiết tại Stream basics và Parallel Stream):

• Quên terminal op — stream.filter(...) không có .toList() hay .forEach(...) → không chạy gì
• Reuse stream — dùng stream sau khi đã có terminal op → IllegalStateException
• sorted() trên infinite stream — hang forever; dùng limit TRƯỚC sorted
• peek cho logic chính — Java 9+ có thể skip peek trên stream SIZED; dùng forEach
• Modify collection gốc trong lambda — forEach(x -> list.add(...)) → ConcurrentModificationException
• limit TRƯỚC sorted — thứ tự op ảnh hưởng kết quả; limit(3).sorted() khác sorted().limit(3)
• parallel với stateful lambda — chia sẻ mutable state giữa thread → race condition
• parallel với I/O — parallelStream() dùng ForkJoinPool common; blocking I/O chặn pool
• NPE từ Optional.get() — dùng orElseThrow() hoặc isPresent() check trước

✅ Self-assessment

Bạn đã đạt module này nếu trả lời được 5 câu sau (match 1-1 với learning outcomes):

• Explain được cơ chế lazy evaluation — tại sao intermediate op chỉ ghi ý định và terminal op mới kích hoạt pipeline, và hệ quả với stream vô hạn và short-circuit
• Implement được stream pipeline với filter/map/reduce/collect trên collection lẫn infinite source — không cần nhìn tài liệu
• Choose được đúng functional interface (Predicate, Function, Consumer, Supplier) và viết method reference tương ứng cho từng stream op
• Diagnose được pitfall stream phổ biến: missing terminal op, stream reuse IllegalStateException, stateful op trên infinite stream
• Compare được imperative loop vs functional stream về readability, memory, và short-circuit behaviour

Module tiếp theo: khi bạn tick được cả 5 ô trên, bạn sẵn sàng cho Java Internals — JVM memory model, GC, concurrency, và performance tuning.