[JAVA] 내가 사랑하는 stream에 대하여...

by yooputer 2024. 10. 24. 22:28

컬렉션(Collection)

유사한 객체 집단을 효율적으로 관리하기 위한 자료구조
List, Set, Map, Queue, Stack, ...
ArrayList는 List 인터페이스를 상속한 클래스

스트림(Stream)

컬렉션, 배열, 입출력 자원과 같은 데이터 집합체를 반복적으로 처리하는 기능
스트림 데이터와 스트림 연산의 개념을 모두 포함
JDK8부터 추가

컬렉션과 스트림의 비교

구분	컬렉션	스트림
처리 방식	다운로드	스트리밍
저장공간	필요	불필요
반복 방식	외부 반복	내부 반복
코드 구현	명령형	선언형
원본 데이터	변경	변경하지 않고 소비
연산 병렬화	어려움	쉬움

스트림 종류

Stream : 객체 원소로 구성
IntStream : int 타입의 원소로 구성
LongStream : long 타입의 원소로 구성
DoubleStream : double 타입의 원소로 구성

스트림 연산 구조

Stream 생성 : 데이터를 Stream으로 변환, 최초 1번 수행
Stream 가공 : 필터, 변형, 정렬 등의 중간 연산. 입력값은 stream, 출력값도 stream. 메서드 체이닝 가능
Stream 소비 : 최종연산 수행. 1번만 수행 가능. 출력값이 stream이 아님

스트림 생성

// ArrayList -> Stream
List<String> list = Arrays.asList("1", "2", ...);
Stream<String> ss = list.stream();

// 배열 -> Stream
String[] array = {"A", "B", "C"};
Stream<String> ss2 = Arrays.stream(array);
Stream<String> ss3 = Stream.of(array);
int[] intArray = {1, 2, 3};
IntStream is = Arrays.stream(intArray);

// Stream 메서드
Stream<String> ss4 = Stream.generate(() -> "ha"); // 무한스트림
Stream<Integer> is2 = Stream.iterate((1, n -> n * 2) // 초기값 1이고, 다음 요소는 이전요소에 2를 곱한 값
IntStream is3 = IntStream.rangeClosed(1, 100) // 1부터 100까지

스트림 중간연산

메서드명	인자	설명
filter	Predicate	true인 요소만 필터링
map	Function	다른 요소로 매핑
mapToInt	ToIntFunction	int로 매핑
mapToLong	ToLongFunction	long으로 매핑
mapToDouble	ToDoubleFunction	double로 매핑
flatMap	Function	중첩된 스트림을 평면화
sorted	X	정렬
sorted	Comparator	주어진 정렬 기준으로 정렬
peek	Consumer	특정 연산 수행
distinct	X	중복 제거
limit	long maxSize	스트림 크기를 n으로 제한
skip	long n	n개 건너뛰기

스트림 최종연산

메서드명	인자	반환값	설명
collect	Collector		특정 자료형으로 변환
toArray		Object[]	배열로 변환
toArray	IntFunction	Object[]	배열로 변환
min	Comparator	Optional<T>	최소값 반환
max	Comparator	Optional<T>	최대값 반환
count		long	요소 개수 반환
anyMatch	Predicate	boolean	한 요소라도 조건을 만족하는지 반환
allMatch	Predicate	boolean	모든 요소가 조건을 만족하는지 반환
noneMatch	Predicate	boolean	모든 요소가 조건을 만족하지 않는지 반환
findFirst		Optional<T>	병렬처리시 stream 순서를 고려하여 가장 첫번째 요소 반환
findAny		Optional<T>	병렬처리시 가장 먼저 찾은 요소 반환(직렬처리시 findFirst와 동일)
forEach	Consumer	void	연산 수행
reduce	BinaryOperator		원소들을 하나씩 소모해가며 누적 계산을 수행하고 결과값 반환