6

我有一个递归分治算法，在开始划分之前需要两个计算密集型的基本案例任务。最初的基本案例是独立的任务，所以我想并行执行它们。在基本情况之后，分割运行相同的任务，不同的输入在 0 和 1 之间，并根据输出决定是否再次分割。我通过创建一个伪造递归的任务包装对象来使基本案例工作，但这感觉就像一个杂物，如下所示：

public static void doSomething () {
    ForkJoinPool pool = new ForkJoinPool();
    private ArrayList<Object> al = new ArrayList<Object>();
    TaskWrapper tw = new TaskWrapper(true,-1);

    al.addAll(pool.invoke(tw));
}

@SuppressWarnings("serial")
public static class TaskWrapper extends RecursiveTask<ArrayList<Object>> {
    private ArrayList<Object> al = new ArrayList<Object>();
    private boolean arg;
    private double input;
    private Object out;

    TaskWrapper(boolean ar, double in){
        arg = ar;
        input = in;
    }

    @Override
    public ArrayList<Object> compute() {
        if (arg == false) {
            out = new Object(runIntensiveTask(input));
            al.add(out);
        }
        else {
            // Right Base Case
            TaskWrapper right = new TaskWrapper(false, 1);
            right.fork();

            // Left Base Case
            TaskWrapper left = new TaskWrapper(false, 0);
            al.addAll(left.compute());

            // Join with Right result
            al.addAll(right.join());
        }
        return al;
    }
}

有没有更简单的方法来完成同样的事情？

这是我的第一篇 StackOverflow 帖子，所以请原谅任何格式或协议错误。感谢您的帮助。

4

1 回答 1

3

人们使用这个框架的方式从来没有让我感到惊讶。简而言之：该框架旨在处理平衡树结构（DAG），当您将其用于其他用途时，就会出现问题。您没有处理平衡树。

Java 需要的是一个通用的并行引擎，但它拥有的是这个框架。所以，你正在尽力而为。如果它有效，很好。我在 Java7 中看不到任何替代方案，但我会更深入地研究。我想知道它在分析器（比如 visualVM）下是如何执行的。因为我没有 intensiveTask 类，所以我无法继续. Java7 中的 join() 创建了可以真正影响应用程序的“连续线程”。让我们知道分析器说什么。

于 2014-03-21T13:50:19.540 回答