Stream terminal operation

---

스트림의 최종연산

• 연산 결과가 스트림이 아닌 연산
• 단 한번만 적용 가능
• 스트림의 요소를 소모

스트림의 최종연산 - forEach() forEachOrdered()

void forEach(Consumer<? super T> action) 
// 병렬 스트림인 경우 순서가 보장되지 않음

void forEachOrdered(Consumer<? super T> action)
// 병렬 스트림인 경우에도 순서가 보장됨

• forEach()
  • 병렬 스트림인 경우 순서가 보장되지 않음 ❌
• forEachOrdered()
  • 병렬 스트림인 경우에도 순서가 보장됨 ✅

IntStream.range(1,10).sequential().forEach(System.out::print);
//123456789

IntStream.range(1,10).sequential().forEachOrdered(System.out::print);
//123456789

• sequential() - 직렬 스트림
  • 스트림은 기본적으로 직렬 스트림

IntStream.range(1,10).parallel().forEach(System.out::print);
//683295714 // 순서 보장 ❌

IntStream.range(1,10).parallel().forEachOrdered(System.out::print);
//123456789 // 순서 보장 ✅

• parallel() - 병렬 스트림
  • 여러 스레드로 나눠서 작업

스트림의 최종 연산 - 조건 검사

조건 검사 allMatch() anyMatch() noneMatch()

boolean allMatch (Predicate<? super T> predicate)
// 모든 요소가 조건을 만족시키면 true

boolean anyMatch (Predicate<? super T> predicate)
// 한 요소라도 조건을 만족시키면 true

boolean noneMatch (Predicate<? super T> predicate)
// 모든 요소가 조건을 만족시키지 않으면 true

boolean hasFailedStu = stuStream.anyMatch(s-> s.getTotalScore()<=100);
// 100 이하가 있는지

조건에 일치하는 요소 찾기 findFirst() findAny()

Optional<T> findFirst()

• 첫 번째 요소를 반환
• 순차 스트림에 사용

Optional<T> findAny()

• 아무거나 하나를 반환
• 병렬 스트림에 사용

Optional<Student> result = stuStream.filter(s->s.getTotalScore() <= 100).findFirst();
Optional<Student> result = parallelStream.filter(s->s.getTotalScore() <= 100).findAny();

• filter() 와 같이 사용

스트림의 최종 연산 - reduce() ⭐

• 스트림의 요소를 하나씩 줄여가며 누적연산 수행 - reduce()
• identity - 초기값
• accumulator - 이전 연산 결과와 스트림의 요소에 수행할 연산

💡 accumulate : 누적하다

// int reduce(int identity, IntBinaryOperator op)
int count = intStream.reduce(0, (a,b) -> a + 1); // count()
int sum = intStream.reduce(0, (a,b) -> a + b); // sum()
int max = intStream.reduce(Integer.MIN_VALUE, (a,b)-> a > b ? a : b); 
// max()
int min = intStream.reduce(Integer.MAX_VALUE, (a,b)-> a < b ? a : b); 
// min 

reduce() 내부 구조

int sum = intStream.reduce(0, (a,b) -> a + b)
// -----> reduce() 내부 구조

int a = identity; // 0

for(int b : stream)
		a = a + b; // sum() // accumulator