java - 并行流功能需要更多时间
问题描述
我有以下函数,它计算遗传算法中每个人的适应度。健身功能需要很长时间,因此对于人口中的每个人来说,都需要很多时间。
Individual fittest = individuals.get(0);
for (int i = 0; i < individuals.size(); i++) {
if (fittest.getFitness() >= getIndividual(i).getFitness()) {
fittest = getIndividual(i);
}
}
return fittest;
我正在尝试以下并行版本,但它比顺序执行更糟糕。
return
individuals.parallelStream().min(Comparator.comparing(GeneticAlgorithm::getFitness)).get();
任何有助于并行计算不同个体的适应度。谢谢
解决方案
只是一个建议。参考下面的代码。
在Individual
课堂上,存储计算的健身。这样您就不必每次都计算它。每当调用任何影响适应度公式的参数的 setter 方法时,您都可以计算适应度。
此外,对于每个解决方案,您可以在并行流中一次计算所有个体的适应度,如代码所示。
public class Test {
public static void main(String[] args) throws Exception {
List<Individual> allSpecimens = new ArrayList<>();
allSpecimens.add(new Individual("a", 50, 4));
allSpecimens.add(new Individual("b", 45, 3));
//after each solution or mutation run following code
allSpecimens.stream().parallel().forEach(s -> {
s.setFitness(GenericAlgorithm.getFitness(s));
});
//find fittest like this
//this should be fater now
Individual fittest = allSpecimens.stream()
.min(Comparator.comparing(Individual::getFitness)).get();
}
}
class GenericAlgorithm {
public static double getFitness(Individual specimen) {
return specimen.getWeight()/specimen.getHeight();
}
}
class Individual{
private String name;
private int height;
private int weight;
//cache calculated fitness
private double fitness;
public Individual(String name, int weight, int height) {
this.name = name;
this.weight = weight;
this.height = height;
//calculate every time you modify a parameter
//remove this if you calculate fitness on all at once
this.fitness = GenericAlgorithm.getFitness(this);
}
public void setHeightAndWeight(int newHeight, int newWeight) {
this.height = newHeight;
this.weight = newWeight;
//calculate every time you modify a parameter
this.fitness = GenericAlgorithm.getFitness(this);
}
public double getFitness(){
//there is no calculations here
//so it is faster now
return fitness;
}
public void setFitness(double fitness) {
this.fitness = fitness;
}
public int getHeight() {
return height;
}
public String getName() {
return name;
}
public int getWeight() {
return weight;
}
}
推荐阅读
- hashmap - Trie vs HashMap,用哪一个——面试题
- python-3.x - 如何在 Python 中每次出现 line.startswith(mystring) 时运行 for-loop
- python - 为什么 cv2.destroyAllWindows 在 if 结构中不起作用?
- assembly - CALLF(Far Call)可以在 Intel 64 架构中有 64 位地址内存操作数吗?
- node.js - 无法安装更好的sqlite3
- z3 - z3中的最大递归界限
- python - 结果 = ibm_db.fetch_both(stmt) -> 值太长。SQLSTATE=22001 SQLCODE=-433
- javascript - Foundation 5 手风琴不能在触摸上工作
- php - 为什么这个 UPDATE 查询会杀死我的 CPU?
- mysql - SQL:选择其他表中不存在的位置