Stream API คืออะไร

Question

Stream API คืออะไร

Accepted Answer

**Stream API** (Java 8+) เปิดใช้งาน **การประมวลผลแบบฟังก์ชัน** ของคอลเล็กชัน — การกรอง การแปลง และการรวบรวมข้อมูลผ่านไปป์ไลน์ของการดำเนินการ แสดงออกมาอย่างเป็นประกาศ (*สิ่งที่* ต้องทำ) มากกว่าลูปอย่างชัดเจน (*วิธีการ*). ## สไตล์ Imperative vs Stream ```java // ❌ imperative — explicit loop, mutable accumulator List result = new ArrayList<>(); for (Person p : people) { if (p.getAge() >= 18) { result.add(p.getName().toUpperCase()); } } // ✅ stream — declarative pipeline, reads like a description of the transformation List result = people.stream() .filter(p -> p.getAge() >= 18) // keep adults .map(p -> p.getName().toUpperCase()) // extract + transform names .collect(Collectors.toList()); // gather into a list ``` เวอร์ชัน stream แสดงเจตนาอย่างชัดเจนเป็นลำดับของการดำเนินการ โดยไม่มีลูปด้วยตนเอง หรือตัวสะสม ## โครงสร้าง Pipeline ```text Source → Intermediate operations (lazy) → Terminal operation (triggers execution) ``` ```java stream() // source .filter(...) .map(...) // intermediate — lazy, return a new stream, chainable .collect(...) // terminal — produces a result, RUNS the pipeline ``` การดำเนินการ **ระดับกลาง** (filter, map, sorted, distinct) นั้น **ขี้เกียจ** — พวกมันสร้างไปป์ไลน์แต่ไม่ทำงานจนกว่าการดำเนินการ **terminal** (collect, forEach, reduce, count) จะเริ่มทำงาน ## การดำเนินการทั่วไป ```java list.stream() .filter(x -> x > 0) // keep matching .map(x -> x * 2) // transform each .sorted() // sort .distinct() // remove duplicates .limit(10) // take first 10 .collect(Collectors.toList()); // aggregations int sum = nums.stream().mapToInt(Integer::intValue).sum(); long count = list.stream().filter(...).count(); Optional first = people.stream().filter(...).findFirst(); boolean any = list.stream().anyMatch(x -> x > 100); // grouping (very powerful) Map> byCity = people.stream().collect(Collectors.groupingBy(Person::getCity)); ``` ## reduce — พับเป็นค่าเดียว ```java int total = nums.stream().reduce(0, (a, b) -> a + b); // sum via reduction ``` ## Parallel streams ```java list.parallelStream().filter(...).collect(...); // process across multiple cores // ⚠️ use only for large data + independent/stateless operations; measure first ``` ## เหตุใดจึงสำคัญ Stream API ปรับปรุงวิธีที่ Java ประมวลผลข้อมูล — แทนที่ลูปที่ยุ่งยากและเสี่ยงต่อข้อผิดพลาดด้วยไปป์ไลน์ที่กระชับ อ่านได้ และประกาศ สำหรับการกรอง แมป การเรียงลำดับ การจัดกลุ่ม และการรวบรวม ใช้อย่างแพร่หลายใน Java สมัยใหม่สำหรับการจัดการข้อมูล ทำให้จุดประสงค์ของโค้ดชัดเจนขึ้น และรวมกับ lambdas และการอ้างอิงวิธีการ เพื่อรูปแบบฟังก์ชัน การทำความเข้าใจแบบจำนวน lazy intermediate / eager terminal eager terminal model, การดำเนินการทั่วไป (filter/map/collect/reduce/groupingBy), และตัวเลือก parallel streams (ด้วยคำเตือนของพวกเขา) จำเป็นต่อการเขียน Java สมัยใหม่ที่เป็น idiomatric Streams เป็นทั้ง productivity boost และหัวข้อการสัมภาษณ์ที่ขึ้นได้บ่อย สะท้อนการบอกเล่าด้วย Java practices ปัจจุบัน