Java 並行プログラミングで並列プログラミングに Fork/Join フレームワークを使用するにはどうすればよいですか?

並列プログラミングに Java Fork/Join フレームワークを使用するにはどうすればよいですか?タスク クラスを作成し、RecursiveAction または RecursiveTask インターフェイスを実装します。フォーク/結合プールを作成し、タスクの実行を管理します。 fork() メソッドを呼び出してタスクをプールに送信し、サブタスクに分解します。 join() メソッドを呼び出してタスクが完了するのを待ち、結果を取得します (RecursiveTask の場合)。

Java 同時プログラミング: Fork/Join フレームワークを使用した並列プログラミング

Fork/Join Framework は、並列タスクを効率的に実行するための軽量フレームワークを提供する Java ライブラリです。これは、スレッドがタスクで共同作業できるようにするワークスチール アルゴリズムに基づいており、それによって CPU リソースの使用率を最大化します。

Fork/Join フレームワークの使用方法:

1. タスク クラスを作成する: このクラスは、java.util.concurrent.RecursiveAction または java.util を実装する必要があります。 concurrent.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()

フォーク/結合プールを作成します:

java.util.concurrent.ForkJoinPool を使用して、スレッド プールを作成します。フォーク/結合タスクの実行を管理します。

フォークタスク:

fork() メソッドを呼び出して、タスクをフォーク/結合プールに送信します。プールはタスクを小さなサブタスクに分割し、それらを使用可能なスレッドに割り当てます。

タスクに参加: 🎜 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 中国語 Web サイトの他の関連記事を参照してください。