* Increase concurrency in TestConcurrentChannelOperationsAsync

lukebakken · lukebakken · commit 1a748f441be3 · 2024-05-09T10:55:55.000-07:00
diff --git a/projects/Test/Integration/TestConcurrentAccessWithSharedConnection.cs b/projects/Test/Integration/TestConcurrentAccessWithSharedConnection.cs
@@ -70,12 +70,14 @@ private async Task TestConcurrentChannelOperationsAsync(Func<IConnection, Task>
             var tasks = new List<Task>();
             for (int i = 0; i < _processorCount; i++)
             {
-                tasks.Add(Task.Run(async () =>
+                tasks.Add(Task.Run(() =>
                 {
+                    var subTasks = new List<Task>();
                     for (int j = 0; j < iterations; j++)
                     {
-                        await action(_conn);
+                        subTasks.Add(action(_conn));
                     }
+                    return Task.WhenAll(subTasks);
                 }));
             }
 

Original file line number	Diff line number	Diff line change
`@@ -70,12 +70,14 @@ private async Task TestConcurrentChannelOperationsAsync(Func<IConnection, Task>`
`70`	`70`	`var tasks = new List<Task>();`
`71`	`71`	`for (int i = 0; i < _processorCount; i++)`
`72`	`72`	`{`
`73`		`- tasks.Add(Task.Run(async () =>`
	`73`	`+ tasks.Add(Task.Run(() =>`
`74`	`74`	`{`
	`75`	`+ var subTasks = new List<Task>();`
`75`	`76`	`for (int j = 0; j < iterations; j++)`
`76`	`77`	`{`
`77`		`- await action(_conn);`
	`78`	`+ subTasks.Add(action(_conn));`
`78`	`79`	`}`
	`80`	`+ return Task.WhenAll(subTasks);`
`79`	`81`	`}));`
`80`	`82`	`}`
`81`	`83`