将线性工作改为并行执行
void processSequentially(List<Element> elements){
for(Element e:elements)
process(e);
}
void processParallel(Executor exec,List<Element>elements){
for(final Element e:elements)
exec.execute(new Runnable()
{
public void run(){
process(e);
}
}
);
}
这些工作应该是独立的。
并行递归：
public <T>void sequentialRecursive(List<Node<T>>nodes,Collection<T>results){
for(Node<T>n:nodes){
results.add(n.computer);
sequentialRecursive(n.getChildren(),results);
}
}
public void parallelRecirsive(final Executor exec,List<Node<T>> nodes,final Collection<T>results){
for(final Node<T> n:nodes){
exec.execute(new Runnable(){
public void run(){
results.add(n.compute());
}
}
);
paralleRecursive(exec,n.getChildren(),results);
}
}
接下来的问题就是等待并行计算的结果了：
exec.shutdown();//关闭，但是会继续执行已提交的任务
exec.awaitTermination(Long.Max_VALUE,TimeUnit.SECONDS);//等待
return resultQueue;