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

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 サイトの他の関連記事を参照してください。