스트림 Stream

정의

sequence of elements supporting sequential and parallel aggregate operations
연속적이고 병렬적인 집계 연산을 지원하는 순서가 있는 요소

• 데이터를 담고 있는 저장소(컬렉션)이 아니다
• 스트림이 처리하는 데이터 소스를 변경하지 않는다
• 스트림으로 처리하는 데이터는 오직 한번만 처리한다 (여러 operation에 대해 한번씩만 적용한다는 뜻)
• 무제한으로 지속적으로 들어오는 값에 대해 스트림으로 받아서 처리할수도 있다
  • Short Circuit 메소드를 사용해서 제한할 수 있다
• 중계 operation은 근본적으로 lazy하다
• 손쉽게 병렬처리할 수 있다

스트림 파이프 라인

• 0 ~ 다수의 중개 오퍼레이션 (intermediate operation)과 1개의 종료 오퍼레이션 (terminal operation)으로 구성된다
• 스트림의 데이터 소스는 오직 터미널 오퍼레이션을 실행할 때만 처리한다

중개 오퍼레이션

• Stream을 리턴한다
• Stateless / Stateful 오퍼레이션으로 구분할 수 있다 (이전 소스 데이터를 참조해야 하는 경우 stateful)
• 종류 : filter, map, limit, count, forEach, min, max ...

종료 오퍼레이션

• Stream을 리턴하지 않는다
• 종류 : collect, allMatch, count, forEach, min, max ...

코드

중개 오퍼레이션과 종료 오퍼레이션

List<String> names = new ArrayList<>();
names.add("woonsik0");
names.add("woonsik1");
names.add("woonsik2");
names.add("woonsik3");
names.add("Koonsik");
names.add("Koonsik1");
names.add("Moonsik");

• 스트림을 리턴하는 중개 오퍼레이션

Stream<String> stringStream = names.stream().map(String::toUpperCase);

• 종료 오퍼레이션이 없이 중개 오퍼레이션만 존재한다면 실행되지 않는다
• 단순히 선언만 이뤄진 상태
• 여기서 출력부분은 실행되지 않는다
• 중계형 operator는 종료형 operator가 오기 전까지 실행되지 않는다
• 그냥 선언만 되있는 상태
• 0 ~ 다수개의 중개 operation과 한개의 종료 operation으로 구성된다

/*List<String> list = */ names.stream().map((s) -> {
	System.out.println(s);
	return s.toUpperCase();
}) /*.collect(Collectors.toList())*/;

/*list.forEach(System.out::println);*/

주석 처리 된 부분이 해제되지 않는다면 아무것도 출력되지 않는다
-> 중개Stream으로만 구성되어있어서 stream을 리턴할뿐 실행은 하지 않으므로
-> 종료Stream이 오면 그때 값을 리턴하고 출력할수 있게 된다

parallelStream 병렬처리

• 스트림에서 병렬적인 처리를 할 수 있다 -> 단, 무조건 빠른게 아니다 상황마다 적용해보고 확인 해봐야된다

List<String> list = names.parallelStream().map(String::toLowerCase)
                .collect(Collectors.toList());

List<String> list1 = names.parallelStream().map((s) -> {
	//아래 출력에서 출력되는 쓰레드가 모두 다른것을 볼수 있다 (병렬적인 처리)
	System.out.println(s + " "+ Thread.currentThread().getName());
	return  s.toUpperCase();
}).collect(Collectors.toList());

list.forEach(System.out::println);
list1.forEach(System.out::println);

/* - 출력값중 prallelStream 내부에서 출력된 부분 -
woonsik2 ForkJoinPool.commonPool-worker-5
Koonsik main
woonsik0 ForkJoinPool.commonPool-worker-27
woonsik1 ForkJoinPool.commonPool-worker-13
woonsik3 ForkJoinPool.commonPool-worker-23
Moonsik ForkJoinPool.commonPool-worker-19
Koonsik1 ForkJoinPool.commonPool-worker-9
*/

참고

oracle_stream
oracle_stream