Scala 2.10のすべてのコレクションの並列度を設定しますか？

Question

変更可能なtasksupportフィールド（c.f. https://stackoverflow.com/a/5425354/82970）を使用して、1つの並列コレクションの並列処理レベルを設定する方法を理解しています。

Scala 2.10の新しい並列コレクションの並列度はどのように設定できますか？

副次的な質問は、tasksupportは、それから構築された新しい並列コレクションによって継承された並列コレクションに関連付けられていますか？ （例えばtake、map、などと）

Answer 1

1. であるように思われ、私は簡単にソースを見て、私が正しく物事を理解していれば、デフォルトの実行コンテキストを設定するために使用することができる3つのシステムプロパティがありますデフォルトのタスクサポートとして使用されます。これらは、タスク・サポート・オブジェクトの並列性レベルを決定します。

   • scala.concurrent.context.minThreads：INT、最小並列度
   • scala.concurrent.context.numThreads：直接使用する並列度を指定するためのInt、または文字列：ダブル続く「X」（例えば「×1.5」 ）、その後、Runtime.getRuntime.availableProcessors
   • scala.concurrent.context.maxThreadsと乗算されます。int、最大並列度

   関連するソースファイルを（私はすべてを正しく従った場合は）ExecutionContextImplのようです。あなたの質問の後半部分については

2. ：
   はmap、filterなどのような操作を変換するには、元のコレクションに設定されているタスクのサポートを維持する必要があります。少なくとも、ソースはそのように見えます。 :)
   ほとんどの並列操作はParIterableLikeで定義されており、resultWithTaskSupportをCombiner（ParIterableLikeの568または581行でファクトリを介して設定された元のタスクサポートを取得）するか、結果のコレクションに直接タスクサポートを設定します。