我是否正确实现了forkjoin？

Question

使用Fork-Join框架的资源，创建一个同步多线程系统，从三个文本文件中形成一个最大长度的单词集合。不要使用中间集合来读取文本。在本例中，工作由存储在MaxLengthWord类的arr字段中的数组表示。createSubtasks（）方法递归地将任务分成更小的工作部分，直到每个工作部分都小于阈值。

    import java.io.File;
import java.util.*;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.RecursiveTask;
import java.util.stream.Collectors;



public class loop {
    public static void main(String[] args) {

        File[] files = {
                new File("text"),
                new File("text2"),
                new File("text3")
        };

        MaxLengthWord sumOfDigits = new MaxLengthWord(files);

        ForkJoinPool pool = new ForkJoinPool();

        final List<String> maxWords = pool.invoke(sumOfDigits);
        System.out.println(maxWords);

    }
}

class MaxLengthWord extends RecursiveTask<List<String>> {
    File[] files;
    private static final int MAXWORDLENGTH = 7;

    public MaxLengthWord(File[] files) {
        this.files = files;
    }

    @Override
    protected List<String> compute() {
        if (files.length > 1) {
            return ForkJoinTask.invokeAll(createSubtasks())
                    .stream()
                    .flatMap(maxLengthWord -> maxLengthWord.join().stream())
                    .collect(Collectors.toList())
                    ;
        } else {
            return processing(files);
        }
    }

    private Collection<MaxLengthWord> createSubtasks() {
        List<MaxLengthWord> subTasks = new ArrayList<>();
        subTasks.add(new MaxLengthWord(
                Arrays.copyOfRange(files, 0, files.length / 2)));
        subTasks.add(new MaxLengthWord(
                Arrays.copyOfRange(files, files.length / 2, files.length)));
        return subTasks;
    }

    private List<String> processing(File[] files) {
        System.out.println(Thread.currentThread());
        List<String> result = new ArrayList<>();
        try (Scanner sc = new Scanner(files[0])) {
            while (sc.hasNext()) {
                String word = sc.next();
                if (word.length() == MAXWORDLENGTH) {
                    result.add(word);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }
}

Answer 1

流。flatMap（）方法需要一个返回流的函数接口。因此，我将join（）方法的结果转换为流。因此，这可能会有所帮助（至少可以编译）：

@Override
protected List<String> compute() {
    if (files.length > 1) {
        return ForkJoinTask.invokeAll(createSubtasks())
                .stream()
                .flatMap(j->j.join().stream())
                .collect(Collectors.toList());
    } else {
        return processing(files);
    }
}