< Java > Stream
Stream 이란?
컬랙션 등의 내부에 있는 요소(element)를 처리하는 방식을 주입해서 그 결과를 빠르게 그리고 쉽게 도출하여 원하는 다음
요소로 변경해서 최종적으로 결과 값을 원하는 연산로직에 쉽게 도출하도록 만드는 요소이다.
매우 다양한 형태가 존재하며 모두 외울 필요는 없다.
또한 이 데이터를 도출할 때는 내부적으로 콜백 형태의 함수형 인터페이스를 받도록 파라미터가 정의 되었기 때문에
반드시 람다를 이용해야만 사용가능합니다.
아래는 코드로 보는 간단한 Stream의 예제입니다.
@AllArgsConstructor
@NoArgsConstructor
@Data
class FullStScore{
// 우리반 학생 점수를 관리하는 클래스
private String name;
private int score;
}
public class StreamEx1 {
public static void main(String[] args) {
List<String> list = new ArrayList();
list.add("가");
list.add("나");
list.add("다");
list.add("라");
list.add("마");
Stream<String> pStream = list.parallelStream();
pStream.forEach(t -> { System.out.println(t);});스트림을 통해 전달될 데이터를 원하는 타입으로 변경 가능하도록 만들 수 있습니다.
대부분 메서드를 통해 변경을 하는데, 하나 주의 해야할 것은 변경이 되면,
변경된 타입의 데이터는 또다른 스트림을 통해 전달된다는 것이다. 꼭 기억하기!!
이렇게 변환되어 전달된 최종 스트림의 데이터는 메서드를 통해서 여러가지 기능의
산술, 정렬 등의 메서드를 통해 결과를 도출 할 수 있습니다.
이때, 꼭 주위해야 할 점은,
집계 요소 메서드를 ( average ) 호출하지 않으면, 중간에 변환된 스트림이 제기능을 못하게 된다는 점이다.
이 스트림 변환은 일반적으로 메서드 체인 방식으로 구현합니다.
아래는 스트림을 통한 데이터 타입의 예입니다.
@AllArgsConstructor
@NoArgsConstructor
@Data
class FullStScore{
// 우리반 학생 점수를 관리하는 클래스
private String name;
private int score;
}
public class StreamEx1 {
public static void main(String[] args) {
List<String> list = new ArrayList();
list.add("가");
list.add("나");
list.add("다");
list.add("라");
list.add("마");
Stream<String> pStream = list.parallelStream();
pStream.forEach(t -> { System.out.println(t);});
FullStScore a = new FullStScore("lee", 100);
FullStScore b = new FullStScore("moon", 48);
FullStScore c = new FullStScore("sun", 77);
ArrayList< FullStScore> score = new ArrayList();
score.add(a);
score.add(b);
score.add(c);
Stream<FullStScore> scoreStream = score.stream();
// 요소의 특정 데이터를 특정 타입으로 변환 하도록하자
IntStream ist = scoreStream.mapToInt( value -> value.getScore());
double avg = ist.average().getAsDouble();
System.out.println("평균 점수 : " + avg);
double avg2 = score.stream().mapToInt(value ->value.getScore()).asDoubleStream().average().getAsDouble();
System.out.println("평균 점수 : " + avg2);
}IntStream
int 타입의 요소를 스트림을 통해 전달하는 스트림이다.
mapToInt() 등의 스트림 변화 메서드를 통해 다른요소의 값을 int로 변환해서 전달하기도하고,
다른 메서드를 통해 특정 범위의 int값을 스트림을 통해 전달 할 수도 있다.
1 ~ 100 사이의 int 값 생성 후 스트림을 통해 전달받는 법을 코드로 보여드리겠습니다.
import java.util.stream.IntStream;
public class IntStreamEx {
static int sum = 0;
public static void main(String[] args) {
//int sum = 0;
//final int sum = 0;
IntStream.range(1, 100).forEach(value -> System.out.println(sum += value)); // 1 부터 99 까지 생성
IntStream.rangeClosed(1, 100).forEach(value -> System.out.println(sum += value)); // 1 부터 100 까지 생성
}
}지역변수 sum이 스트림 내부에서 람다의 변수로 사용되면 지역 익명객체의 target 변수가 된다.
자바에서는 4개의 중첩이 존재하는데,
이 중 지역 중첩은 지역 (메서드) 내의 변수를 중첩 클래스에서 사용 할 시엔 반드시 final 로 선언이 되어야 한다.
때문에, 지역 sum 이 final 로 선언하면 가능하나 reassign 이 안되기 때문에 static member 로 선언해서 사용한다.
줄이자면, Stream에서 값을 변경하기위해 reassign 을 이용하려면 static member로 선언해야한다 !!