.net 8 parallel sync #203

christiannagel · christiannagel · commit 87e87b8313bc · 2025-02-09T14:00:48.000+01:00
diff --git a/2_Libs/Parallel/SynchronizationSamples/BarrierSample/BarrierSample.csproj b/2_Libs/Parallel/SynchronizationSamples/BarrierSample/BarrierSample.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net6.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>
diff --git a/2_Libs/Parallel/SynchronizationSamples/BarrierSample/Program.cs b/2_Libs/Parallel/SynchronizationSamples/BarrierSample/Program.cs
@@ -80,7 +80,7 @@ private static void CalculationInTask(int jobNumber, int partitionSize, Barrier
 
         for (int i = 0; i < loops; i++)
         {
-            List<string> data = new(coll[i]);
+            List<string> data = [.. coll[i]];
 
             int start = jobNumber * partitionSize;
             int end = start + partitionSize;
diff --git a/2_Libs/Parallel/SynchronizationSamples/EventSample/EventSample.csproj b/2_Libs/Parallel/SynchronizationSamples/EventSample/EventSample.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net6.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>
diff --git a/2_Libs/Parallel/SynchronizationSamples/EventSample/Program.cs b/2_Libs/Parallel/SynchronizationSamples/EventSample/Program.cs
@@ -10,7 +10,7 @@
     mEvents[i] = new(false);
     waitHandles[i] = mEvents[i].WaitHandle;
     calcs[i] = new(mEvents[i]);
-    Task.Run(() => calcs[i1].Calculation(i1 + 1, i1 + 3));
+    _ = Task.Run(() => calcs[i1].Calculation(i1 + 1, i1 + 3));
 }
 
 for (int i = 0; i < taskCount; i++)
diff --git a/2_Libs/Parallel/SynchronizationSamples/EventSampleWithCountdownEvent/Calculator.cs b/2_Libs/Parallel/SynchronizationSamples/EventSampleWithCountdownEvent/Calculator.cs
@@ -6,7 +6,6 @@
 
     public Calculator(CountdownEvent ev) => _cEvent = ev;
 
-
     public void Calculation(int x, int y)
     {
         Console.WriteLine($"Task {Task.CurrentId} starts calculation");
diff --git a/2_Libs/Parallel/SynchronizationSamples/EventSampleWithCountdownEvent/EventSampleWithCountdownEvent.csproj b/2_Libs/Parallel/SynchronizationSamples/EventSampleWithCountdownEvent/EventSampleWithCountdownEvent.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net6.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>
diff --git a/2_Libs/Parallel/SynchronizationSamples/EventSampleWithCountdownEvent/Program.cs b/2_Libs/Parallel/SynchronizationSamples/EventSampleWithCountdownEvent/Program.cs
@@ -1,13 +1,13 @@
 ﻿const int taskCount = 4;
 
-CountdownEvent cEvent = new(taskCount);
+using CountdownEvent cEvent = new(taskCount);
 Calculator[] calcs = new Calculator[taskCount];
 
 for (int i = 0; i < taskCount; i++)
 {
     calcs[i] = new(cEvent);
     int i1 = i;
-    Task.Run(() => calcs[i1].Calculation(i1 + 1, i1 + 3));
+    _ = Task.Run(() => calcs[i1].Calculation(i1 + 1, i1 + 3));
 }
 
 cEvent.Wait();
@@ -17,5 +17,3 @@
 {
     Console.WriteLine($"task for {i}, result: {calcs[i].Result}");
 }
-
-cEvent.Dispose();
diff --git a/2_Libs/Parallel/SynchronizationSamples/LockAcrossAwait/LockAcrossAwait.csproj b/2_Libs/Parallel/SynchronizationSamples/LockAcrossAwait/LockAcrossAwait.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net6.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>
diff --git a/2_Libs/Parallel/SynchronizationSamples/LockAcrossAwait/Program.cs b/2_Libs/Parallel/SynchronizationSamples/LockAcrossAwait/Program.cs
@@ -5,7 +5,7 @@ class Program
     static async Task Main()
     {
         await RunUseSemaphoreAsync();
-        await RunUseAsyncSempahoreAsync();
+        await RunUseAsyncSemaphoreAsync();
         Console.ReadLine();
     }
 
@@ -24,7 +24,7 @@ static async Task Main()
     static async Task RunUseSemaphoreAsync()
     {
         Console.WriteLine(nameof(RunUseSemaphoreAsync));
-        string[] messages = { "one", "two", "three", "four", "five", "six" };
+        string[] messages = ["one", "two", "three", "four", "five", "six"];
         Task[] tasks = new Task[messages.Length];
 
         for (int i = 0; i < messages.Length; i++)
@@ -41,9 +41,9 @@ static async Task RunUseSemaphoreAsync()
         Console.WriteLine();
     }
 
-    static async Task RunUseAsyncSempahoreAsync()
+    static async Task RunUseAsyncSemaphoreAsync()
     {
-        Console.WriteLine(nameof(RunUseAsyncSempahoreAsync));
+        Console.WriteLine(nameof(RunUseAsyncSemaphoreAsync));
         string[] messages = { "one", "two", "three", "four", "five", "six" };
         Task[] tasks = new Task[messages.Length];
 
@@ -61,7 +61,7 @@ static async Task RunUseAsyncSempahoreAsync()
         Console.WriteLine();
     }
 
-    private static SemaphoreSlim s_asyncLock = new SemaphoreSlim(1);
+    private static SemaphoreSlim s_asyncLock = new(1);
     static async Task LockWithSemaphore(string title)
     {
         Console.WriteLine($"{title} waiting for lock");
@@ -78,7 +78,7 @@ static async Task LockWithSemaphore(string title)
         }
     }
 
-    private static AsyncSemaphore s_asyncSemaphore = new AsyncSemaphore();
+    private static AsyncSemaphore s_asyncSemaphore = new();
     static async Task UseAsyncSemaphore(string title)
     {
         using (await s_asyncSemaphore.WaitAsync())
diff --git a/2_Libs/Parallel/SynchronizationSamples/ReaderWriterLockSample/ReaderWriter.cs b/2_Libs/Parallel/SynchronizationSamples/ReaderWriterLockSample/ReaderWriter.cs
@@ -1,6 +1,6 @@
 ﻿sealed class ReaderWriter : IDisposable
 {
-    private List<int> _items = new() { 0, 1, 2, 3, 4, 5 };
+    private List<int> _items = [0, 1, 2, 3, 4, 5];
     private ReaderWriterLockSlim _rwl = new();
     private bool disposedValue;
 
@@ -24,7 +24,7 @@ public void ReaderMethod(object? reader)
 
     public void WriterMethod(object? writer)
     {
-        Console.WriteLine($"Startring writer {writer}");
+        Console.WriteLine($"Starting writer {writer}");
         try
         {
             while (!_rwl.TryEnterWriteLock(50))
diff --git a/2_Libs/Parallel/SynchronizationSamples/ReaderWriterLockSample/ReaderWriterLockSample.csproj b/2_Libs/Parallel/SynchronizationSamples/ReaderWriterLockSample/ReaderWriterLockSample.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net6.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>
diff --git a/2_Libs/Parallel/SynchronizationSamples/SemaphoreSample/SemaphoreSample.csproj b/2_Libs/Parallel/SynchronizationSamples/SemaphoreSample/SemaphoreSample.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net6.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>
diff --git a/2_Libs/Parallel/SynchronizationSamples/SingletonUsingMutex/SingletonUsingMutex.csproj b/2_Libs/Parallel/SynchronizationSamples/SingletonUsingMutex/SingletonUsingMutex.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net6.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>
diff --git a/2_Libs/Parallel/SynchronizationSamples/SynchronizatonSamples/Job.cs b/2_Libs/Parallel/SynchronizationSamples/SynchronizatonSamples/Job.cs
@@ -1,4 +1,4 @@
-﻿namespace SynchronizatonSamples;
+﻿namespace SynchronizationSamples;
 
 public class Job
 {
diff --git a/2_Libs/Parallel/SynchronizationSamples/SynchronizatonSamples/Program.cs b/2_Libs/Parallel/SynchronizationSamples/SynchronizatonSamples/Program.cs
@@ -1,4 +1,4 @@
-﻿using SynchronizatonSamples;
+﻿using SynchronizationSamples;
 
 int numTasks = 20;
 SharedState state = new();
diff --git a/2_Libs/Parallel/SynchronizationSamples/SynchronizatonSamples/SharedState.cs b/2_Libs/Parallel/SynchronizationSamples/SynchronizatonSamples/SharedState.cs
@@ -1,4 +1,4 @@
-﻿namespace SynchronizatonSamples;
+﻿namespace SynchronizationSamples;
 
 public class SharedState
 {
diff --git a/2_Libs/Parallel/SynchronizationSamples/SynchronizatonSamples/SynchronizatonSamples.csproj b/2_Libs/Parallel/SynchronizationSamples/SynchronizatonSamples/SynchronizatonSamples.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net6.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>
diff --git a/2_Libs/Parallel/SynchronizationSamples/ThreadingIssues/ThreadingIssues.csproj b/2_Libs/Parallel/SynchronizationSamples/ThreadingIssues/ThreadingIssues.csproj
@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net6.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>

Original file line number	Diff line number	Diff line change
`@@ -80,7 +80,7 @@ private static void CalculationInTask(int jobNumber, int partitionSize, Barrier`
`80`	`80`
`81`	`81`	`for (int i = 0; i < loops; i++)`
`82`	`82`	`{`
`83`		`- List<string> data = new(coll[i]);`
	`83`	`+ List<string> data = [.. coll[i]];`
`84`	`84`
`85`	`85`	`int start = jobNumber * partitionSize;`
`86`	`86`	`int end = start + partitionSize;`
Original file line number	Diff line number	Diff line change
`@@ -10,7 +10,7 @@`
`10`	`10`	`mEvents[i] = new(false);`
`11`	`11`	`waitHandles[i] = mEvents[i].WaitHandle;`
`12`	`12`	`calcs[i] = new(mEvents[i]);`
`13`		`- Task.Run(() => calcs[i1].Calculation(i1 + 1, i1 + 3));`
	`13`	`+ _ = Task.Run(() => calcs[i1].Calculation(i1 + 1, i1 + 3));`
`14`	`14`	`}`
`15`	`15`
`16`	`16`	`for (int i = 0; i < taskCount; i++)`
Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,6 @@`
`6`	`6`
`7`	`7`	`public Calculator(CountdownEvent ev) => _cEvent = ev;`
`8`	`8`
`9`		`-`
`10`	`9`	`public void Calculation(int x, int y)`
`11`	`10`	`{`
`12`	`11`	`Console.WriteLine($"Task {Task.CurrentId} starts calculation");`
Original file line number	Diff line number	Diff line change
`@@ -1,13 +1,13 @@`
`1`	`1`	`const int taskCount = 4;`
`2`	`2`
`3`		`-CountdownEvent cEvent = new(taskCount);`
	`3`	`+using CountdownEvent cEvent = new(taskCount);`
`4`	`4`	`Calculator[] calcs = new Calculator[taskCount];`
`5`	`5`
`6`	`6`	`for (int i = 0; i < taskCount; i++)`
`7`	`7`	`{`
`8`	`8`	`calcs[i] = new(cEvent);`
`9`	`9`	`int i1 = i;`
`10`		`- Task.Run(() => calcs[i1].Calculation(i1 + 1, i1 + 3));`
	`10`	`+ _ = Task.Run(() => calcs[i1].Calculation(i1 + 1, i1 + 3));`
`11`	`11`	`}`
`12`	`12`
`13`	`13`	`cEvent.Wait();`
`@@ -17,5 +17,3 @@`
`17`	`17`	`{`
`18`	`18`	`Console.WriteLine($"task for {i}, result: {calcs[i].Result}");`
`19`	`19`	`}`
`20`		`-`
`21`		`-cEvent.Dispose();`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@ class Program`
`5`	`5`	`static async Task Main()`
`6`	`6`	`{`
`7`	`7`	`await RunUseSemaphoreAsync();`
`8`		`- await RunUseAsyncSempahoreAsync();`
	`8`	`+ await RunUseAsyncSemaphoreAsync();`
`9`	`9`	`Console.ReadLine();`
`10`	`10`	`}`
`11`	`11`
`@@ -24,7 +24,7 @@ static async Task Main()`
`24`	`24`	`static async Task RunUseSemaphoreAsync()`
`25`	`25`	`{`
`26`	`26`	`Console.WriteLine(nameof(RunUseSemaphoreAsync));`
`27`		`- string[] messages = { "one", "two", "three", "four", "five", "six" };`
	`27`	`+ string[] messages = ["one", "two", "three", "four", "five", "six"];`
`28`	`28`	`Task[] tasks = new Task[messages.Length];`
`29`	`29`
`30`	`30`	`for (int i = 0; i < messages.Length; i++)`
`@@ -41,9 +41,9 @@ static async Task RunUseSemaphoreAsync()`
`41`	`41`	`Console.WriteLine();`
`42`	`42`	`}`
`43`	`43`
`44`		`- static async Task RunUseAsyncSempahoreAsync()`
	`44`	`+ static async Task RunUseAsyncSemaphoreAsync()`
`45`	`45`	`{`
`46`		`- Console.WriteLine(nameof(RunUseAsyncSempahoreAsync));`
	`46`	`+ Console.WriteLine(nameof(RunUseAsyncSemaphoreAsync));`
`47`	`47`	`string[] messages = { "one", "two", "three", "four", "five", "six" };`
`48`	`48`	`Task[] tasks = new Task[messages.Length];`
`49`	`49`
`@@ -61,7 +61,7 @@ static async Task RunUseAsyncSempahoreAsync()`
`61`	`61`	`Console.WriteLine();`
`62`	`62`	`}`
`63`	`63`
`64`		`- private static SemaphoreSlim s_asyncLock = new SemaphoreSlim(1);`
	`64`	`+ private static SemaphoreSlim s_asyncLock = new(1);`
`65`	`65`	`static async Task LockWithSemaphore(string title)`
`66`	`66`	`{`
`67`	`67`	`Console.WriteLine($"{title} waiting for lock");`
`@@ -78,7 +78,7 @@ static async Task LockWithSemaphore(string title)`
`78`	`78`	`}`
`79`	`79`	`}`
`80`	`80`
`81`		`- private static AsyncSemaphore s_asyncSemaphore = new AsyncSemaphore();`
	`81`	`+ private static AsyncSemaphore s_asyncSemaphore = new();`
`82`	`82`	`static async Task UseAsyncSemaphore(string title)`
`83`	`83`	`{`
`84`	`84`	`using (await s_asyncSemaphore.WaitAsync())`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`sealed class ReaderWriter : IDisposable`
`2`	`2`	`{`
`3`		`- private List<int> _items = new() { 0, 1, 2, 3, 4, 5 };`
	`3`	`+ private List<int> _items = [0, 1, 2, 3, 4, 5];`
`4`	`4`	`private ReaderWriterLockSlim _rwl = new();`
`5`	`5`	`private bool disposedValue;`
`6`	`6`
`@@ -24,7 +24,7 @@ public void ReaderMethod(object? reader)`
`24`	`24`
`25`	`25`	`public void WriterMethod(object? writer)`
`26`	`26`	`{`
`27`		`- Console.WriteLine($"Startring writer {writer}");`
	`27`	`+ Console.WriteLine($"Starting writer {writer}");`
`28`	`28`	`try`
`29`	`29`	`{`
`30`	`30`	`while (!_rwl.TryEnterWriteLock(50))`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-namespace SynchronizatonSamples;`
	`1`	`+namespace SynchronizationSamples;`
`2`	`2`
`3`	`3`	`public class Job`
`4`	`4`	`{`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-using SynchronizatonSamples;`
	`1`	`+using SynchronizationSamples;`
`2`	`2`
`3`	`3`	`int numTasks = 20;`
`4`	`4`	`SharedState state = new();`