Scala 2.10 tüm koleksiyonları için paralellik düzeyini ayarlama?

Question

Ben değişken tasksupport alan (Bakınız: https://stackoverflow.com/a/5425354/82970) üzerinden, tek bir paralel toplama paralellik düzeyini ayarlamak için nasıl anlıyoruz.

Scala 2.10'daki tüm yeni paralel koleksiyonlar için paralellik düzeyini nasıl ayarlayabilirim?

bir yan soru --- bunun dışında yerleşik yeni paralel koleksiyonları ile paralel bir koleksiyon 'miras' olarak ilişkili tasksupport mı? (Örn take, map, vb)

Answer 1

1. Ben kaynaklar kısaca baktım ve doğru şeyleri anlamak eğer gibi görünüyor varsayılan yürütme içeriği, yapılandırmak için kullanılabilecek üç sistem özellikleri vardır varsayılan görev desteği olarak kullanılır. Bunlar görev desteği nesnenin paralellik düzeyini belirlemek.

   • scala.concurrent.context.minThreads: Int, asgari paralellik seviyesi
   • scala.concurrent.context.numThreads: ya bir Int, doğrudan kullanmak paralellik düzeyini belirtin veya bir dize: Bir çift tarafından izlenen bir "x" (örneğin "x1.5"), sonra Runtime.getRuntime.availableProcessors
   • scala.concurrent.context.maxThreads ile çarpıldığı: Int, maksimum paralellik seviyesini

   ilgili kaynak dosyası (her şeyi doğru takip varsa) ExecutionContextImpl gibi görünüyor. Sorunuzun ikinci kısmına gelince

2. :
   dönüştürme işlemleri map gibi filter vb menşeli koleksiyonu ayarlanmış görev desteği korumalıdır. En azından kaynaklar öyle görünüyor. :)
   Çoğu paralel işlem ParIterableLike olarak tanımlanmıştır ve(Combiner numaralı telefondan) (bunlar, 561 veya 581 numaralı satırlarda fabrika tarafından başlatılan başlangıç ​​görevi desteği alır ve ParIterableLike'da) görev desteğini doğrudan elde edilen koleksiyona ayarlar.