Java Academy · 강의

병렬 스트림 생성

parallel()과 parallelStream()을 알아봅니다

병렬 스트림 생성은(는) CoddyKit의 무료 Java Academy 강의입니다. 이것은 4개 중 1번째 강의입니다. 아래에서 전체 강의를 무료로 읽을 수 있으며, 내장 코드 에디터와 24/7 AI 튜터와 함께 브라우저에서 직접 실습할 수 있습니다. 이 강의는 Java Academy 학습 경로의 일부이며, 진행 상황이 웹과 CoddyKit 앱에 동기화됩니다. Java Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

병렬 스트림의 동작

병렬 스트림은 데이터를 나누어 여러 스레드에서 조각을 처리한 다음 결과를 결합합니다. 목표는 대규모 작업에서 처리량을 높이는 것입니다.

import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        int sum = IntStream.rangeClosed(1, 1000)
            .parallel()
            .sum();
        System.out.println(sum);
    }
}

기존 스트림에서 parallel() 사용하기

parallel()을 호출하면 순차 스트림이 병렬 스트림으로 바뀝니다. 파이프라인의 어느 위치에나 배치할 수 있습니다.

import java.util.List;

public class Main {
    public static void main(String[] args) {
        List<Integer> nums = List.of(1, 2, 3, 4, 5);
        int total = nums.stream()
            .parallel()
            .mapToInt(Integer::intValue)
            .sum();
        System.out.println(total);
    }
}

컬렉션에서 parallelStream() 사용하기

Collection.parallelStream()은 병렬 스트림을 직접 생성하며, stream().parallel()을 간단히 줄여 쓴 형태입니다.

import java.util.List;

public class Main {
    public static void main(String[] args) {
        List<String> words = List.of("a", "bb", "ccc");
        int chars = words.parallelStream()
            .mapToInt(String::length)
            .sum();
        System.out.println(chars);
    }
}

순차 실행으로 돌아가기

sequential()은 스트림을 단일 스레드 실행으로 되돌립니다. 전체 파이프라인에는 마지막으로 호출된 parallel() 또는 sequential()이 적용됩니다.

import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        int sum = IntStream.rangeClosed(1, 100)
            .parallel()
            .sequential()
            .sum();
        System.out.println(sum);
    }
}

isParallel 확인하기

isParallel()은 스트림이 병렬로 실행되는지 알려 줍니다.

import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        System.out.println(IntStream.range(0, 10).isParallel());
        System.out.println(IntStream.range(0, 10).parallel().isParallel());
    }
}

동일한 결과, 다른 실행 방식

합계처럼 결합법칙이 성립하는 연산에서는 병렬 스트림과 순차 스트림이 동일한 결과를 반환합니다. 다른 점은 실행 전략뿐입니다.

import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        int seq = IntStream.rangeClosed(1, 50).sum();
        int par = IntStream.rangeClosed(1, 50).parallel().sum();
        System.out.println(seq == par);
    }
}

공용 ForkJoinPool

병렬 스트림은 공유되는 ForkJoinPool.commonPool()을 사용합니다. 기본 크기는 사용 가능한 프로세서 수에서 1을 뺀 값입니다.

public class Main {
    public static void main(String[] args) {
        System.out.println(Runtime.getRuntime().availableProcessors());
    }
}

스레드 순서는 보장되지 않습니다

forEach를 사용하면 병렬 스트림에서는 조각이 완료되는 시간이 서로 다르므로 어떤 순서로든 출력될 수 있습니다. 순서가 중요하다면 forEachOrdered를 사용하십시오.

import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        IntStream.rangeClosed(1, 5)
            .parallel()
            .forEachOrdered(System.out::println);
    }
}

축약으로 부분 결과 결합하기

내부적으로 병렬 축약은 각 조각에 대한 부분 결과를 계산한 뒤 결합기로 병합합니다. 올바르게 동작하려면 연산에 결합법칙이 성립해야 합니다.

import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        int product = IntStream.rangeClosed(1, 6)
            .parallel()
            .reduce(1, (a, b) -> a * b);
        System.out.println(product);
    }
}

병렬로 수집하기

수집기 프레임워크는 부분 컨테이너를 병합하여 병렬 수집을 지원합니다. groupingBy는 병렬 환경에서도 올바르게 동작합니다.

import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

public class Main {
    public static void main(String[] args) {
        List<String> words = List.of("apple", "banana", "avocado", "cherry");
        Map<Character, List<String>> byFirst = words.parallelStream()
            .collect(Collectors.groupingBy(w -> w.charAt(0)));
        System.out.println(byFirst);
    }
}

모든 스트림이 더 빨라지는 것은 아닙니다

병렬성을 켜는 일은 간단하지만 항상 이점이 있는 것은 아닙니다. 데이터 세트가 작거나 연산이 가벼우면 분할과 병합에 드는 오버헤드 때문에 병렬 실행이 더 느릴 수 있습니다.

import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        long count = IntStream.rangeClosed(1, 10)
            .parallel()
            .filter(n -> n % 2 == 0)
            .count();
        System.out.println(count);
    }
}

빠른 확인

기본적으로 병렬 스트림을 실행하는 스레드 풀은 무엇인가요?

복습

병렬 스트림을 만드는 방법을 배웠습니다:

parallel()은 모든 스트림을 변환하고, parallelStream()은 컬렉션을 위한 간단한 방법입니다.
sequential()은 순차 실행으로 되돌리며, 마지막 호출이 적용됩니다.
병렬 스트림은 공유되는 ForkJoinPool.commonPool()에서 실행됩니다.
결합법칙이 성립하는 연산에서는 결과가 순차 실행과 일치하지만, 순서와 속도는 보장되지 않습니다.

자주 묻는 질문

“병렬 스트림 생성” 강의는 무료인가요?

네 — “병렬 스트림 생성” 전체 내용을 이 웹사이트에서 무료로 읽을 수 있습니다. 인터랙티브하게 실습하려면(내장 코드 에디터와 24/7 AI 튜터), CoddyKit PRO로 업그레이드하면 Java Academy 강의 전체를 잠금 해제할 수 있습니다. Java Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

“병렬 스트림 생성”에서 뭘 배우나요?

parallel()과 parallelStream()을 알아봅니다 브라우저에서 직접 실행하는 실습 코드로 Java Academy을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.

Java Academy을(를) 시작하는 데 경험이 필요한가요?

사전 경험은 필요하지 않습니다. CoddyKit의 Java Academy은(는) 초급자부터 고급 학습자까지를 위해 구성되어 있으므로, 여기서 시작하거나 처음부터 시작할 수 있으며 자신의 속도대로 진행할 수 있습니다. 이것은 4개 중 1번째 강의입니다.

“병렬 스트림 생성” 강의는 얼마나 걸리나요?

대부분의 CoddyKit 강의는 약 5~10분이 소요됩니다. 각 강의는 간결하고 인터랙티브하여 꾸준한 진행이 가능하며, 웹과 앱에서 중단한 부분부터 바로 시작할 수 있습니다.

이 Java Academy 강의에서 코드를 작성하고 실행할 수 있나요?

네. 모든 Java Academy 강의에는 내장 코드 에디터가 포함되어 있으므로, 브라우저에서 바로 실제 코드를 작성하고 실행한 후 즉시 AI 피드백을 받을 수 있습니다 — 로컬 설정이 필요 없습니다.

이 강의의 모든 강의

← Java Academy(으)로 돌아가기