Java 8 병렬 스트림에 대한 스레드 풀을 어떻게 사용자 정의할 수 있습니까?

Java 8 병렬 스트림용 스레드 풀 사용자 정의

Java 8에서는 데이터 집약적인 작업을 위한 효율적인 병렬 처리를 제공하는 병렬 스트림을 도입했습니다. 그러나 병렬 스트림에 대한 사용자 정의 스레드 풀을 지정하는 것은 여전히 ​​파악하기 어려운 기능입니다. 이 문서에서는 ForkJoinPool을 사용한 해결 방법을 제시하여 이 문제를 다룹니다.

기본 스레드 풀과 관련된 주요 관심사 중 하나는 차단 동작의 가능성입니다. 한 스트림에서 느리게 실행되는 작업은 다른 병렬 스트림의 실행을 방해할 수 있습니다. 이는 격리가 중요한 다중 스레드 애플리케이션에서 특히 문제가 됩니다.

이러한 제한을 극복하기 위해 각 작업에 대해 전용 ForkJoinPool을 만들 수 있습니다. 해당 ForkJoinPool 내에서 별도의 작업으로 병렬 스트림을 실행하면 스트림은 기본 스레드 풀 대신 지정된 스레드 풀을 활용하여 격리된 상태로 유지됩니다.

다음 코드 조각을 고려하세요.

final int parallelism = 4;
ForkJoinPool forkJoinPool = null;
try {
    forkJoinPool = new ForkJoinPool(parallelism);
    final List<Integer> primes = forkJoinPool.submit(() ->
        IntStream.range(1, 1_000_000).parallel()
                .filter(PrimesPrint::isPrime)
                .boxed().collect(Collectors.toList())
    ).get();
    System.out.println(primes);
} catch (InterruptedException | ExecutionException e) {
    throw new RuntimeException(e);
} finally {
    if (forkJoinPool != null) {
        forkJoinPool.shutdown();
    }
}

이 코드는 지정된 병렬 처리를 사용하여 새 ForkJoinPool을 생성하고 그 안에서 병렬 스트림을 실행합니다. 병렬 스트림은 격리된 풀에서 작동하여 다른 스레드의 잠재적인 간섭을 방지합니다.

이 접근 방식을 사용하면 스레드 할당을 더 효과적으로 제어할 수 있으므로 개발자는 병렬 스트림을 구분하고 멀티 스레드 애플리케이션 내에서 리소스 효율성을 보장할 수 있습니다.

위 내용은 Java 8 병렬 스트림에 대한 스레드 풀을 어떻게 사용자 정의할 수 있습니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!