[java] 스트림을 이용한 병렬 Sorted

07 Dec 2023

java

자바 8부터 소개된 스트림(Stream)은 컬렉션 처리를 쉽고 효율적으로 할 수 있는 기능입니다. 스트림은 데이터를 처리하는 연산을 지연 실행할 수 있고, 파이프라인 형식으로 연속된 연산을 수행할 수 있습니다. 이렇게 처리된 스트림은 병렬 처리를 통해 더 빠르게 처리할 수 있습니다.

스트림을 사용하여 데이터를 정렬하는 작업 중, 병렬로 처리하면 성능을 향상시킬 수 있습니다. 자바에서는 스트림의 sorted() 메소드를 사용하여 데이터를 정렬할 수 있습니다. 이 메소드를 사용할 때, parallel() 메소드를 함께 사용하면 스트림을 병렬로 처리할 수 있습니다.

아래는 병렬로 정렬하는 예제 코드입니다.

import java.util.Arrays;
import java.util.List;

public class ParallelSortedExample {

    public static void main(String[] args) {
        List<Integer> numbers = Arrays.asList(3, 1, 4, 2, 5);

        numbers.parallelStream()
               .sorted()
               .forEach(System.out::println);
    }
}

위 코드에서는 Integer 타입의 리스트를 생성하고, parallelStream() 메소드를 호출하여 병렬 스트림을 생성합니다. 그리고 sorted() 메소드를 사용하여 데이터를 정렬한 후, forEach() 메소드를 호출하여 정렬된 결과를 출력합니다.

이 코드를 실행하면 정렬된 결과가 병렬로 출력되는 것을 확인할 수 있습니다. 이때, 병렬 처리를 수행하는 동안 자바 런타임은 멀티코어 프로세서를 최대한 활용하여 처리합니다.

스트림을 사용하여 데이터를 병렬로 정렬할 때, 주의해야 할 점이 있습니다. sorted() 메소드는 요소 전체에 대해 정렬을 수행하기 때문에 처리량이 많은 작업일 경우 성능 저하가 발생할 수 있습니다. 이럴 경우에는 병렬 정렬 대신 다른 방법을 고려해야 할 수도 있습니다.

다음은 이에 대한 참고 자료입니다: