Java 동시 프로그래밍에서 병렬 프로그래밍을 위해 Fork/Join 프레임워크를 사용하는 방법은 무엇입니까?

병렬 프로그래밍을 위해 Java Fork/Join 프레임워크를 사용하는 방법은 무엇입니까? 작업 클래스를 만들고 RecursiveAction 또는 RecursiveTask 인터페이스를 구현합니다. Fork/Join 풀을 생성하고 작업 실행을 관리합니다. fork() 메서드를 호출하여 작업을 풀에 제출하고 하위 작업으로 분해합니다. Join() 메서드를 호출하여 작업이 완료되고 결과를 얻을 때까지 기다립니다(RecursiveTask의 경우).

Java 동시 프로그래밍: Fork/Join 프레임워크를 사용한 병렬 프로그래밍

Fork/Join 프레임워크는 병렬 작업을 효율적으로 실행하기 위한 경량 프레임워크를 제공하는 Java 라이브러리입니다. 이는 스레드가 작업에 대해 협업할 수 있게 하여 CPU 리소스 활용도를 최대화하는 작업 도용 알고리즘을 기반으로 합니다.

Fork/Join 프레임워크 사용 방법:

1. 작업 클래스 생성: 이 클래스는 java.util.concurrent.RecursiveAction 또는 java.util을 구현해야 합니다. 동시.RecursiveTask 인터페이스. RecursiveAction은 값을 반환하지 않는 작업을 수행하는 데 사용되는 반면 RecursiveTask는 수행합니다. java.util.concurrent.RecursiveAction 或 java.util.concurrent.RecursiveTask 接口。RecursiveAction 用于执行不返回值的任务，而 RecursiveTask 则会返回值。
2. 创建一个 Fork/Join 池：使用 java.util.concurrent.ForkJoinPool 创建一个线程池。它将管理 Fork/Join 任务的执行。
3. Fork 任务：调用 fork() 方法将任务提交给 Fork/Join 池。池会将任务分解成更小的子任务，并分配给可用的线程。
4. Join 任务：调用 join()

Fork/Join 풀 만들기:

java.util.concurrent.ForkJoinPool을 사용하여 스레드 풀을 만듭니다. Fork/Join 작업의 실행을 관리합니다.

작업 포크:

fork() 메서드를 호출하여 작업을 Fork/Join 풀에 제출합니다. 풀은 작업을 더 작은 하위 작업으로 나누고 이를 사용 가능한 스레드에 할당합니다.

Join 작업: 🎜join() 메서드를 호출하고 작업이 완료될 때까지 기다립니다. RecursiveTask의 경우 반환 값을 기본 스레드에도 반환합니다. 🎜🎜🎜🎜실용 예: 🎜🎜🎜숫자 목록에 있는 모든 홀수의 합을 계산하는 병렬 작업이 있다고 가정합니다. 다음과 같이 Fork/Join 프레임워크를 사용하여 이를 구현할 수 있습니다. 🎜

import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveAction;

public class OddSumTask extends RecursiveAction {
    private int[] numbers;
    private int start;
    private int end;

    public OddSumTask(int[] numbers, int start, int end) {
        this.numbers = numbers;
        this.start = start;
        this.end = end;
    }

    @Override
    protected void compute() {
        int sum = 0;
        for (int i = start; i < end; i++) {
            if (numbers[i] % 2 != 0) {
                sum += numbers[i];
            }
        }
        System.out.println("Partial sum: " + sum);
    }
}

public class Main {
    public static void main(String[] args) {
        // 创建一个数字列表
        int[] numbers = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};

        // 创建一个 Fork/Join 池
        ForkJoinPool pool = new ForkJoinPool();

        // 创建一个 OddSumTask
        OddSumTask task = new OddSumTask(numbers, 0, numbers.length);

        // Fork 任务
        pool.invoke(task);
    }
}

🎜 이 코드를 실행하면 목록에 홀수 숫자가 추가되고 각 스레드에서 계산된 로컬 합계가 인쇄됩니다. 🎜

위 내용은 Java 동시 프로그래밍에서 병렬 프로그래밍을 위해 Fork/Join 프레임워크를 사용하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!