Java Academy · 강의

흔한 함정

순서, 박싱, 공용 풀을 다룹니다

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

병렬 실행이 항상 빠른 것은 아닙니다

parallel()을 추가하면 코드가 빨라지는 대신 느려질 수 있습니다. 이 수업에서는 이를 피할 수 있도록 대표적인 함정을 다룹니다.

import java.util.stream.IntStream;

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

함정: 순서 지정 오버헤드

forEachOrdered나 limit처럼 순서를 보장하는 연산은 스레드 간 조정을 강제하므로 병렬 실행의 이점을 줄입니다.

import java.util.stream.IntStream;

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

unordered가 도움이 될 수 있습니다

순서가 중요하지 않다면 unordered()를 호출하여 실행 환경이 순서 관련 작업을 건너뛰고 더 자유롭게 병렬화하도록 할 수 있습니다.

import java.util.stream.IntStream;

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

함정: 숨겨진 박싱

병렬 환경에서 Stream<Integer>를 사용하면 스레드마다 박싱 비용이 증가합니다. 숫자를 병렬 처리할 때는 기본형 스트림을 우선 사용하십시오.

import java.util.stream.IntStream;

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

함정: 공유되는 공용 풀

모든 병렬 스트림은 하나의 ForkJoinPool.commonPool()을 공유합니다. 긴 병렬 작업 하나가 같은 JVM의 다른 작업, 애플리케이션의 다른 부분을 포함하여 다른 작업의 실행을 막을 수 있습니다.

import java.util.concurrent.ForkJoinPool;

public class Main {
    public static void main(String[] args) {
        System.out.println(ForkJoinPool.commonPool().getParallelism());
    }
}

사용자 지정 풀에서 작업 격리하기

무거운 작업이 공용 풀에서 실행되지 않도록 하려면 자체 ForkJoinPool 내부에서 병렬 스트림을 제출하십시오.

import java.util.concurrent.ForkJoinPool;
import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) throws Exception {
        ForkJoinPool pool = new ForkJoinPool(2);
        long sum = pool.submit(() ->
            IntStream.rangeClosed(1, 1_000_000).parallel().asLongStream().sum()
        ).get();
        pool.shutdown();
        System.out.println(sum);
    }
}

함정: 분할이 잘 되지 않는 원본

LinkedList, Stream.iterate, BufferedReader.lines는 분할이 잘 되지 않습니다. 이를 병렬화해도 이점이 거의 없거나 오히려 성능이 저하되는 경우가 많습니다.

import java.util.stream.Stream;

public class Main {
    public static void main(String[] args) {
        long n = Stream.iterate(1, x -> x + 1)
            .limit(100_000)
            .parallel()
            .filter(x -> x % 2 == 0)
            .count();
        System.out.println(n);
    }
}

함정: 상태가 있는 람다

외부 상태를 읽거나 쓰는 람다는 병렬 환경에서 비결정적으로 동작합니다. 일관된 결과를 얻으려면 상태가 없도록 유지하십시오.

import java.util.stream.IntStream;

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

함정: findFirst와 findAny

findFirst는 순서를 지켜야 하므로 병렬 환경에서 오버헤드가 추가됩니다. 일치하는 요소 중 아무거나 괜찮다면 findAny를 사용하십시오.

import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        int found = IntStream.rangeClosed(1, 1_000_000).parallel()
            .filter(n -> n % 99991 == 0)
            .findAny()
            .getAsInt();
        System.out.println(found);
    }
}

함정: 작은 데이터에 대한 가벼운 연산

컬렉션이 매우 작거나 작업이 사소하면 분할과 병합에 드는 오버헤드가 모든 이점을 압도합니다. 순차 실행을 유지하십시오.

import java.util.List;

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

함정: 수집기의 비용이 큰 병합

큰 정렬 구조를 만드는 것처럼 병합 단계의 비용이 큰 수집기는 병렬 실행의 이점을 상쇄할 수 있습니다. 단순한 누적은 저렴하게 병합됩니다.

import java.util.stream.IntStream;

public class Main {
    public static void main(String[] args) {
        long total = IntStream.rangeClosed(1, 1_000_000).parallel()
            .mapToLong(n -> n)
            .sum();
        System.out.println(total);
    }
}

빠른 확인

병렬 스트림에서 findFirst가 findAny보다 느릴 수 있는 이유는 무엇인가요?

복습

병렬 실행에서 흔히 발생하는 함정을 배웠습니다:

순서 지정(forEachOrdered, limit, findFirst)에는 조정 비용이 추가됩니다. 가능하면 unordered나 findAny를 사용하십시오.
박싱은 비용을 증가시키므로 기본형 스트림을 우선 사용하십시오.
공유되는 공용 풀이 다른 작업의 실행을 막을 수 있으므로, 무거운 작업은 사용자 지정 ForkJoinPool에서 격리하십시오.
분할이 잘 되지 않는 원본, 작은 데이터, 비용이 큰 병합은 모두 병렬성을 저해합니다.

자주 묻는 질문

“흔한 함정” 강의는 무료인가요?

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

“흔한 함정”에서 뭘 배우나요?

순서, 박싱, 공용 풀을 다룹니다 브라우저에서 직접 실행하는 실습 코드로 Java Academy을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.

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

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

“흔한 함정” 강의는 얼마나 걸리나요?

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

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

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

이 강의의 모든 강의

← Java Academy(으)로 돌아가기