Я смотрел новые параллельные коллекции Scala 2.9 и надеюсь отказаться от многих моих непослушных любительских версий подобных вещей. В частности, я хотел бы заменить пул соединений fork, который лежит в основе реализации по умолчанию, чем-то своим (например, чем-то, что распределяет оценку задач по сети через акторов). Насколько я понимаю, это просто вопрос применения парадигмы Scala «наращиваемых модификаций», но библиотека коллекций достаточно пугает, и я не совсем уверен, какие биты нужно изменить!
Некоторые конкретные вопросы:
ForkJoinTasks
? FutureThreadPoolTasks
. Как мне создать коллекцию, которая использует эту черту вместо ForkJoinTasks
? AdaptiveWorkStealingTasks
и каким-то образом создавать экземпляр экземпляры коллекций, которые используют эту новую черту? (Для справки, все упомянутые выше характеристики определены в Tasks.scala .)
Особенно приветствуются примеры кода!