paralléliser création de tableau

Question

F #

[|for index in 1 .. items.Count()-1 -> (* create object here - complex operations *)|] 

C#

Object[] newItemArray= new Object[items.Count]; 

Parallel.For(0, items.Count, index=> 
{ 
    /*complex stuff here*/ 
    newItemArray[index] = new Object(); 
}); 

J'ai ci-dessus C# et F # faire la même chose. Sans le Parallel.For, le F # est légèrement plus rapide. Avec le Parallel.For, le C# prend moitié moins de temps à s'exécuter. Comment paralléliser correctement le F # pour obtenir le même boost de performance que le C#? La façon dont j'ai essayé jusqu'ici était Array.Parallel.Iteri, donc je pourrais utiliser le même index dans un truc de tableau que j'ai utilisé en C#, mais il l'a ralenti au lieu de l'accélérer.

Edit:

Plus de détails sur ce que je fais:

J'ai un dénombrable de byte array array array. J'ai un autre byte array array array auquel je compare les autres. Je suis en train de trier l'énumérable sur% similarity et de renvoyer les 500 premiers.

Dans les deux F # et C# je fais une simple boucle imbriquée qui incrémente un compteur. Une fois la boucle bouclée sur un élément particulier de mon énumérable, je crée un tuple de (item, counter). Une fois que j'ai créé mon nouvel élément énumérable de (item, counter), je le trierai sur la variable du compteur, récupèrerai les 500 premiers et ensuite je les convertirai en un élément énumérable.

La partie que je suis en train de l'intérieur du Parallel.For est la création du IEnumerable<Tuple<item, int>>

Answer 1

Vous ne devriez pas utiliser la compréhension du tableau dans ce cas. C'est un peu plus lent que les fonctions de haut niveau et ne peut pas être parallélisé.

Bien que je préférerais @ solution de ildjarn, voici une solution équivalente à votre C# un:

// You need an uninitialized array to fill in later 
let newItemArray = Array.zeroCreate items.Count 

// Fill in the array in a parallel manner 
Array.Parallel.iteri (fun i v -> 
    (* create object here - complex operations *)) newItemArray 

Vous pouvez également utiliser Parallel.For directement:

let newItemArray = Array.zeroCreate items.Count 

Parallel.For(0, items.Count, 
      (fun index -> 
       (* complex stuff here *) 
       newItemArray.[index] <- Object()) 
) |> ignore 

Il est plus bavard, mais donne vous avez plus de contrôle sur degree of parallelism.

Answer 2

Array.Parallel.init items.Count (fun index -> 
    (* create object here - complex operations *)) 

Documentation officielle: Parallel.init<'T> Function (F#)