thi đua một scala ParStream

Question

Một mô hình không phải là hiếm trong vấn đề dự án Euler có vẻ là một cái gì đó tương đương với:

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

trong đó f là một số chức năng để đắt-tính toán trả về giá trị tích cực đến một lúc nào đó không rõ, và trả về số không sau đó.

Tôi thích những thứ song song, đặc biệt là khi các bộ sưu tập song song của Scala và .par làm cho việc này trở nên dễ dàng. Tuy nhiên, trong sự vắng mặt của một ParStream, tốt nhất mà tôi đưa ra là:

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

mà không có vẻ rất thanh lịch và rất nhạy cảm với sự lựa chọn giá trị BATCH (nhưng có thể mang lại những cải thiện tốc độ x4 trên của tôi bốn nhân).

Bất kỳ đề xuất nào cho các cách rõ ràng hơn để đạt được cùng một kết quả?

Answer 1

Vâng, bạn có thể làm cho nó một chút thanh lịch hơn với một cái gì đó giống như Stream from 1 grouped BATCH map (_.par), mặc dù tôi muốn sử dụng Iterator trong trường hợp này - trọng lượng nhẹ hơn nhiều so với Stream, và nó sẽ không lấp đầy bộ nhớ REPL như tôi thử nghiệm với nó.