JAVA - stream

pararelleStream. 병렬처리가 항상 빠른 것은 아니다. 병렬처리가 효과가 클때는 데이터가 정말 방대할 때이다.

 

8. Stream 소개

Stream

• ●  sequence of elements supporting sequential and parallel aggregate operations

• ●  데이터를 담고 있는 저장소 (컬렉션)이 아니다.

• ●  Funtional in nature, 스트림이 처리하는 데이터 소스를 변경하지 않는다.

• ●  스트림으로 처리하는 데이터는 오직 한번만 처리한다.

• ●  무제한일 수도 있다. (Short Circuit 메소드를 사용해서 제한할 수 있다.)

• ●  중개 오퍼레이션은 근본적으로 lazy 하다.

• ●  손쉽게병렬처리할수있다.

스트림 파이프라인

• ●  0 또는 다수의 중개 오퍼레이션 (intermediate operation)과 한개의 종료 오퍼레이션

  (terminal operation)으로 구성한다.

• ●  스트림의 데이터 소스는 오직 터미널 오퍼네이션을 실행할 때에만 처리한다.

  중개 오퍼레이션

• ●  Stream을 리 한다.

• ●  Stateless / Stateful 오퍼레이션으로 더 상세하게 구분할 수도 있다. (대부분은

  Stateless지만 distinct나 sorted 처럼 이전 이전 소스 데이터를 참조해야 하는

  오퍼레이션은 Stateful 오퍼레이션이다.)

• ●  filter, map, limit, skip, sorted, ...

  종료 오퍼레이션

• ●  Stream을 리턴하지 않는다.

• ●  collect, allMatch, count, forEach, min, max, ...

  참고

• ●  https://docs.oracle.com/javase/8/docs/api/java/util/stream/package-summary.html

• ●  https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html

java.util.stream (Java Platform SE 8 )

Stream (Java Platform SE 8 )

 

 

 

import java.util.*;
import java.util.function.Predicate;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import java.util.ArrayList;
import java.util.List;

public class App {

public static void main(String[] args) {
List<OnlineClass> springClasses = new ArrayList<>();
springClasses.add(new OnlineClass(1, "spring boot", true));
springClasses.add(new OnlineClass(2, "spring data jpa", true));
springClasses.add(new OnlineClass(3, "spring mvc", false));
springClasses.add(new OnlineClass(4, "spring core", false));
springClasses.add(new OnlineClass(5, "rest api development", false));

List<OnlineClass> javaClasses = new ArrayList<>();
javaClasses.add(new OnlineClass(6, "The Java, Test", true));
javaClasses.add(new OnlineClass(7, "The Java, Code manipulation", true));
javaClasses.add(new OnlineClass(8, "The Java, 8 to 11", false));

List<List<OnlineClass>> keesunEvents = new ArrayList<>();
keesunEvents.add(springClasses);
keesunEvents.add(javaClasses);

System.out.println("spring 으로 시작하는 수업");
for (OnlineClass onlineClass : springClasses) {
if (onlineClass.getTitle().startsWith("spring")) {
Integer id = onlineClass.getId();
System.out.println(id);
}
}

System.out.println("close 되지 않은 수업");


System.out.println("수업 이름만 모아서 스트림 만들기");
springClasses.stream()
.map(oc -> oc.getTitle())
.forEach(System.out::println);


System.out.println("두 수업 목록에 들어있는 모든 수업 아이디 출력");
// springClasses.stream().forEach(x -> System.out.println(x.getId()));
// javaClasses.stream().forEach(x -> System.out.println(x.getId()));

keesunEvents.stream()
.flatMap(Collection::stream)
.forEach(oc -> System.out.println(oc.getId()));

System.out.println("10부터 1씩 증가하는 무제한 스트림 중에서 앞에 10개 빼고 최대 10개 까지만");
Stream.iterate(10, i -> i+1)
.skip(10)
.limit(10)
.forEach(System.out::println);

System.out.println("자바 수업 중에 Test가 들어있는 수업이 있는지 확인");
boolean test = javaClasses.stream().anyMatch(oc -> oc.getTitle().contains("Test"));
System.out.println(test);

System.out.println("스프링 수업 중에 제목에 spring이 들어간 제목만 모아서 List로 만들기");

List<String> spring = springClasses.stream()
.map(OnlineClass::getTitle)
.filter(t -> t.contains("spring"))
.collect(Collectors.toList());
for (String s : spring) {
System.out.println(s);
}


}

}