bir scala ParStream

Question

bir öykünen Proje Euler sorunlar nadir değildir desen eşdeğer bir şey gibi görünüyor:

f bilinmeyen bir noktaya kadar olumlu değerleri döndürür bazı pahalı-to-bilgi işlem fonksiyonu olan

Stream.from(1).map(f).takeWhile((_>0)).foldLeft(0L)(_+_) 

ve Bundan sonra sıfırlar döndürür.

Özellikle Scala'nın paralel koleksiyonları ve .par'un işleri kolaylaştırması gibi şeyleri paralel hale getirmek istiyorum. Ama bir ParStream yokluğunda, iyi ben ile geldim: çok şık görünüyor ve BATCH değerin seçimine duyarlıdır (ancak üzerinde x4 hız artışı sağlayabilir gelmez

val BATCH=1024 
Stream.from(1,BATCH).flatMap(
    i=>(i until i+BATCH).par.map(f) 
).takeWhile((_>0)).foldLeft(0L)(_+_) 

benim dört çekirdekli).

Aynı sonuca ulaşmanın daha temiz yolları için önerileriniz var mı?

Answer 1

Eh, doğrusu bu durumda Iterator kullanmayı tercih olsa, Stream from 1 grouped BATCH map (_.par) gibi bir şey ile biraz daha şık yapabilirsiniz - daha hafif ağırlık Stream daha, ben denemeler gibi Repl hafızasını doldurmak olmaz o.