Parallelisierung mit Fork-Join Pool

This commit is contained in:
Florian Steurer 2016-04-22 16:52:16 +02:00
parent 7d75f18319
commit 856f5da86b

View File

@ -33,6 +33,8 @@ import de.dhbwstuttgart.typeinference.unify.model.UnifyType;
*/
public class TypeUnifyTask extends RecursiveTask<Set<Set<UnifyPair>>> {
private static final long serialVersionUID = 1L;
/**
* The implementation of setOps that will be used during the unification
*/
@ -163,8 +165,6 @@ public class TypeUnifyTask extends RecursiveTask<Set<Set<UnifyPair>>> {
/*
* Step 6 a) Restart (fork) for pairs where subst was applied
*/
Set<TypeUnifyTask> restart = new HashSet<>();
if (eqPrime.equals(eq))
eqPrimePrimeSet.add(eqPrime);
else if(eqPrimePrime.isPresent()) {
@ -172,12 +172,10 @@ public class TypeUnifyTask extends RecursiveTask<Set<Set<UnifyPair>>> {
forks.add(fork);
fork.fork();
}
//eqPrimePrimeSet.addAll(this.unify(eqPrimePrime.get(), fc));
else {
TypeUnifyTask fork = new TypeUnifyTask(eqPrime, fc);
forks.add(fork);
fork.fork();
// eqPrimePrimeSet.addAll(this.unify(eqPrime, fc));
}
}