Différences

Ci-dessous, les différences entre deux révisions de la page.

--- developpement:dotnet:csharp:introduction [2023/10/04 23:35] – [Continuation with state] sgariepy
+++ developpement:dotnet:csharp:introduction [2023/10/05 15:11] – [PLINQ] sgariepy
@@ Ligne 1442: / Ligne 1442: @@
 }
+</code>
+===== PLINQ =====
+Parallel LINQ:
+  * Automates parallelization
+  * Considéré déclaratif plutôt qu'impératif
+  * Opérateurs qui font en sorte que ce n'est pas parallélisé:
+    * Take, Select, SelectMany, Skip, TakeWhile, SkipWhile, ElementAt
+  * Anomalies
+    * Join, GroupBy, GroupJoin, Distinct, Union, Intersect, Except
+  * Force parallelism:
+    * .AsParallel().withExecutionMode(ParallelExecution.ForceParallelism)
+<code csharp>
+void Main()
+{
+    var list = Enumerable.Range(1, 100000);
+    var primeNumbers = list
+                        .AsParallel()
+                        .Where(IsPrime);
+    Console.WriteLine("{0} prime numbers", primeNumbers.Count());
+}
+bool IsPrime(int x)
+{
+    if (x == 1) return false;
+    if (x == 2) return true;
+    if (x % 2 == 0) return false;
+    var boundary = (int)Math.Floor(Math.Sqrt(x));
+    for (int i = 3; i <= boundary; i += 2)
+    {
+        if (x % i == 0)
+        {
+            return false;
+        }
+    }
+    return true;
+}
+</code>
+==== Degree of Parallelism ====
+<code csharp>
+void Main()
+{
+    List<string> websites = new List<string>();
+    websites.Add("apple.com");
+    websites.Add("google.com");
+    websites.Add("microsoft.com");
+    List<PingReply> responses = websites
+                                    .AsParallel()
+                                    .WithDegreeOfParallelism(websites.Count())
+                                    .Select(PingSites)
+                                    .ToList();
+    foreach (var response in responses)
+    {
+        Console.WriteLine(response.Address + " " + response.Status + " " + response.RoundtripTime);
+    }
+    Console.ReadLine();
+}
+private static PingReply PingSites(string websiteName)
+{
+    Ping ping = new Ping();
+    return ping.Send(websiteName);
+}
 </code>