Создание параллельной коллекции с 2.8

Question

Я бы хотел сделать что-то вроде этого:

(1 to 100).parallel(20).filter(_ > 20).foreach(sendViaHttp)
List(1,3,5,9,100).parallel(3).map(fetchFromDatabase)

Это означает: «взять коллекцию, создать пул потоков с N потоками, запустить фильтр и т. Д. В этом пуле потоков». Мое понимание 2.8 коллекций (и scala в целом) поверхностно. Я возился с CanBuildFrom, но я почти уверен, что то, что я делаю, неверно или просто плохая идея.

Может ли кто-нибудь помочь с примерами или указателями?

Answer 1

Агрегирование комментариев к приемлемому ответу:

Если вы можете переключиться на Scala 2.9 с встроенным параллельными коллекциями

Если вы хотите контролировать количествопараллельных потоков вы можете сделать это, используя совет здесь .