Haskell'de Paralel Stratejiler Nasıl Kullanılır

Question

Paralel olarak kullanmak istediğim bir frequencyBy işlevim var. Ben paralel frequencyBy yılında map çalıştırmak istiyorum

import Control.Parallel.Strategies 
import Control.DeepSeq 
import System.Environment 

frequencyBy :: (a -> b -> Bool) -> [a] -> [b] -> [(a,Int)] 
frequencyBy f as bs = map 
    (\a ->(a, foldr (\b -> if f a b then (+) 1 else id) 0 bs)) as 

main :: IO() 
main = do 
    x:xs <- getArgs 
    let result = frequencyBy (==) [1::Int .. 10000] [1 .. (read x)] `using` 
       parList rdeepseq 
    print $ product $ map snd $ result 

: Burada basit bir test durumda izler. Bunu parList rdeepseq kullanarak (main'daki diğer tüm öğeler, yalnızca her şeyin en iyi duruma getirilmediğinden emin olmak için) kullanmaya çalışıyorum. Ancak, bu işe yaramıyor, iki iş parçacığı aynı anda iki iş parçacığı kadar çalışır. Burada ne yapıyorum anlamadım.

Answer 1

Bu yükün ne kadar büyük olduğunu x; eğer her kıvılcımda yaptığınız iş, her kıvılcımı üretmek için gereken süreye eşdeğer ise (ve tabii ki, zamanlama yükü, vb.), o zaman problemlerle karşılaşırsınız.

parListChunk, örn. parListChunk 64 rdeepseq; Hangi chunk boyutunun kullanılacağını anlamaya çalışmalısınız. Mevcut stratejiniz, listenin tüm öğeleri için bir kıvılcım oluştururken, parListChunk, listedeki belirli bir boyuttaki her yığın için bir kıvılcım oluşturur ve bu öbek öğesinin her öğesi için sırayla belirttiğiniz stratejiyi kullanır.

Bu arada, frequencyBy'daki foldr, muhtemelen aşırı sersemlik oluşturma nedeniyle işleri yavaşlatıyor; Bu sorunu gidermek için

.

Elbette, her zaman olduğu gibi, -O2 ile derlediğinizden ve +RTS -N ile çalıştığınızdan emin olun.

Answer 2

Bence paralellik çok ince taneli. parList, her öğeyi paralel olarak değerlendirmeye çalışır ve gerçekten tek bir öğe için o kadar çok iş yoktur.

parList'dan parListChunk 500'a değiştirdiğimde, yürütme süresi neredeyse% 50 artar; Bende olduğu kadar iyi bir çift çekirdekli makinede olduğum gibi.

Referans için, x=20000 ile test ediyordum.