스트림의 최종 연산(조건 검사, 통계, 리듀싱)

1. forEach()

- peek()와 달리 스트림의 요소를 소모하는 최종연산자이다.

 

void forEach(Consumer<? super T> action)

 

 

 

 

2. 조건 검사 - allMatch(), anyMatch(), noneMatch(), findFirst(), findAny()

- 조건 검사 메서드들은 매개변수로 Predicate를 요구하며, boolean을 반환한다.

 

(1) boolean allMatch (Predicate<? super T> predicate)

(2) boolean anyMatch (Predicate<? super T> predicate)

(3) boolean noneMatch (Predicate<? super T> predicate)

 

 

( 예를 들어, 학생들 총점이 담겨져 있는 stuStream있다고 하자. )

( 이 스트림에 총점이 100 이하인 학생이 있는지 확인하는 코드는 아래와 같이 쓴다. )

 

boolean noFailed = stuStream.anyMatch(s -> s.getTotalScore() <= 100);

 

 

( 이 외에도 findFirst()를 사용하여 조건에 일치하는 첫번째 요소를 반환한다. )
( 주로 filter() 메서드와 함께 쓰인다. )

( 만약 병렬 스트림이라면, findFirst()가 아닌 findAny()를 사용해야 한다. )

 

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

Optional<Student> stu2 = ParallelStream.filter(s -> s.getTotalScore() <= 100).findAny();

 

( findAny()와 findFirst()의 반환 타입은 Optional<T>이다. )

( 만약 스트림의 요소가 없을 때에는 비어있는 Optional 객체를 반환한다. )

 

 

 

 

3. 통계 - count(), sum(), average(), max(), min()

- IntStream과 같은 기본형 스트림에는 스트림의 요소들에 대한 통계 정보를 얻을 수 있는

메서드들이 있다.

 

 

- 그러나, 기본형 스트림이 아닌 경우에는 아래의 메서드 3개 뿐이다.

 

(1) long count()

(2) Optional<T> max(Comparator<? super T> comparator)

(3) Optional<T> min(Comparator<? super T> comparator)

 

 

 

 

4. 리듀싱 - reduce()

- reduce() 메서드는 스트림의 요소를 줄여나가면서 연산을 수행하고 최종결과를 반환한다.

그러므로, 매개변수의 타입은 BinaryOperator<T> 인 것이다.

 

Optional<T> reduce(BinaryOperator<T> accumlator)

 

 

- 이 외에도 연산결과의 초기값(매개변수 identity)을 갖는 reduce()도 있는데, 초기값과 스트림의 첫 번째

요소로 시작한다. 만약 스트림의 요소가 하나도 없는 경우, 초기값이 반환된다.

 

T reduce(T identity, BinaryOperator<T> accumulator)

U reduce(U identity, BiFunction<U,T,U> accumulator, BinaryOperator<U> combiner)

 

 

- 최종 연산 count()와 sum(), max(), min()은 내부적으로 모두 reduce()를 이용해서 아래와 같이 작성되었다.

 

int count = intStream.reduce(0, (a,b) -> a+1);

int sum = intStream.reduce(0, (a,b) -> a+b);

int max = intStream.reduce(Integer.MIN_VALUE, (a,b) -> a>b ? a:b);

int min = intStream.reduce(Integer.MAX_VALUE, (a,b) -> a<b ? a:b);

 

( 사실 max()와 min()의 경우, 초기값이 필요없으므로 Optional<T>를 사용하는 것이 낫다. )

( 단, intStream 참조변수의 타입이 IntStream인 경우, OptionalInt를 사용해야 한다. )

( 왜냐하면 IntStream에 정의된 reduce()는 OptionalInt를 반환하기 때문이다. )

 

OptionalInt max = intStream.reduce((a,b) -> a>b ? a:b);

OptionalInt min = intStream.reduce((a,b) -> a<b ? a:b);

또는

OptionalInt max = intStream.reduce(Integer::max);

OptionalInt min = intStream.reduce(Integer::min);

 

( 또한 OptionalInt에서 값을 꺼낼 때는 아래의 코드처럼 수행하면 된다. )

 

int maxValue = max.getAsInt();

 

 

 

 

5. 위에서 했던 이론을 이해하기 위한 예제(1)