Java 7: пример Fork/Join - правильно ли я понял?

Question

Я запачкаю руки с помощью функции параллелизма и параллелизма Java 7 - Fork/Join Framework.

Я пытаюсь отобразить список всех каталогов по указанному пути. Может кто-нибудь сказать мне, правильно ли я понял?

Вот мой основной класс - JoinForkExample, с которого начинается задача

package com.skilledmonster.examples;

import java.io.File;
import java.util.List;
import java.util.concurrent.ForkJoinPool;

public class JoinForkExample {
    public static void main(String[] args) {
        ForkJoinPool forkJoinPool = new ForkJoinPool() ;
        List<File> directories = forkJoinPool.invoke(new DirectoryListingTask(new File("C:/xampp"))) ;
         for (int i = 0; i < directories.size(); i++) {
            File file = (File) directories.get(i);
            System.out.println(file.getAbsolutePath());
        }
    }
}

И вот моя актуальная задача

package com.skilledmonster.examples;

import java.io.File;
import java.io.FileFilter;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.RecursiveTask;

public class DirectoryListingTask extends RecursiveTask<List<File>> {

    private static final FileFilter filter = new DirectoryFilter();

    private File file ;

    public DirectoryListingTask(File file) {
        this.file = file;
    }

    @Override
    protected List<File> compute() {
       List<RecursiveTask<List<File>>> forks = new LinkedList<>(); 
       List files = new ArrayList();
        if (file.isDirectory()) {
            File[] filteredFiles = file.listFiles(filter);
            if (null != filteredFiles) {
                files.addAll(Arrays.asList(filteredFiles));
            }
            for (File childFile : file.listFiles()) {
                DirectoryListingTask task = new DirectoryListingTask(childFile);
                forks.add(task);
                task.fork();
            }

            for (RecursiveTask<List<File>> task : forks) {
                files.addAll(task.join());
            }
        }
        return files ;
    }
}

Я в значительной степени получаю намеченный результат. Но я не совсем уверен, правильно ли я понял. И удивительно, я не замечаю никакой разницы во времени выполнения, даже когда я выполнял то же самое без использования структуры соединения / разветвления.

Какие-нибудь мысли!

Answer 1

Так как эта работа в основном связана с IO, здесь не очень полезно использовать Fork/Join. Я бы предложил вместо этого попробовать некоторые задачи, требующие больших вычислительных ресурсов. Также обратите внимание, что операция Fork/Join имеет накладные расходы. Если вы используете его для вычисления ряда Фибоначчи, это не заслуживает этого. И я ожидаю, что производительность будет ниже, чем в последовательной версии.