1

ForkJoinPool を使用してタスクを並行して実行します。プログラムのログアウト出力を見ると、ForkJoinPool がタスクを実行するために大量のワーカーを作成しているようです (次のようなログ エントリがあります05 Apr 2016 11:39:18,678 [ForkJoinPool-2-worker-2493] <message>)。

ForkJoinPool で構成した並列処理の数に従って実行される、作成された各タスクのワーカーがありますか、それとも何か間違っていますか? これが私がそれを行う方法です：

public class MyClass {
    private static final int NUM_CORES = Runtime.getRuntime().availableProcessors();
    public MyClass() {
        int maxThreads = NUM_CORES * 2;
        this.forkJoinPool = new ForkJoinPool(maxThreads);
    }

    public void doStuff() {  
        final int[] toIndex = {0};
        forkJoinPool.submit(() -> {
            List<ForkJoinTask> tasks = new ArrayList<>();
            while (toIndex[0] < objects.size()) {
                toIndex[0] += 20;
                List<Object> bucket = objects.subList(toIndex[0] - 20, toIndex[0]);
                ForkJoinTask task = new UpdateAction(bucket);
                tasks.add(task);
                task.fork();
            }
            tasks.forEach(ForkJoinTask::join);
        }).join();
    }

    private class UpdateAction extends RecursiveAction {

        private List<Object> bucket;

        private UpdateAction(List<Object> bucket) {
            this.bucket = bucket;
        }

        @Override 
        protected void compute() {
            // do some calculation
        }
    }
}
4

2 に答える 2

1

あなたは、膨大な数のワーカー スレッドについて正しいです。これは 2011 年に書いたもので、現在でも有効です。フレームワークは適切な join() を実行できないため、新しいワーカー スレッドを作成するか停止します。

于 2016-04-05T14:34:28.267 に答える