Ich habe eine Funktion frequencyBy , die ich parallelisieren möchte. Hier folgt ein einfacher Testfall:
Ich möchte das map in frequencyBy parallel ausführen. Ich versuche das mit parList rdeepseq zu erreichen (all die anderen Sachen in main sollen nur sicherstellen, dass nicht alles weg optimiert ist). Dies funktioniert jedoch nicht, zwei Threads machen doppelt so viel Arbeit wie ein Thread in der gleichen Zeit. Ich verstehe nicht, was ich hier falsch mache.
Es könnte sein, dass der Overhead die Dinge verlangsamt, je nachdem, wie groß x ist; Wenn die Arbeit, die du in jedem Funken machst, vergleichbar ist mit der Zeit, die es braucht, um jeden Funken zu spawnen (und natürlich gibt es einen Zeitplan-Overhead usw.), dann wirst du auf Probleme stoßen.
Sie könnten parListChunk parListChunk 64 rdeepseq einen Funken für jedes Stück einer bestimmten Größe in der Liste und verwendet die Strategie, die Sie sequentiell für jedes Element dieses Stücks angeben.
By the way, die parListChunk in foldr verlangsamt wahrscheinlich die Dinge aufgrund übermäßiger Thunk-Erstellung; etwas wie
sollte das beheben.
Natürlich, wie immer, stellen Sie sicher, dass Sie mit frequencyBy kompilieren und mit -O2 laufen.
Ich denke, Ihre Parallelität ist zu feinkörnig. parList versucht, jedes Element parallel zu bewerten, und es gibt wirklich nicht viel Arbeit für ein einzelnes Element.
Wenn ich von parList zu parListChunk 500 wechsel, erhöht sich die Ausführungszeit um fast 50%; da ich auf einer Dual-Core-Maschine bin, die ungefähr so gut ist wie es geht.
Als Referenz habe ich mit x=20000 getestet.
Tags und Links haskell parallel-processing