Index: test/Common/DelftTools.Utils.Tests/Threading/ThreadedWorkerTest.cs =================================================================== diff -u -r18f9b18cab9da0c768badb3084415e993a5414ee -r5fc71a385897af92ccb092f2f969b5709afab85a --- test/Common/DelftTools.Utils.Tests/Threading/ThreadedWorkerTest.cs (.../ThreadedWorkerTest.cs) (revision 18f9b18cab9da0c768badb3084415e993a5414ee) +++ test/Common/DelftTools.Utils.Tests/Threading/ThreadedWorkerTest.cs (.../ThreadedWorkerTest.cs) (revision 5fc71a385897af92ccb092f2f969b5709afab85a) @@ -15,15 +15,17 @@ const int timePerWorkItem = 50; const int numWorkItems = 20; const int sequentialTime = numWorkItems*timePerWorkItem; - const double maxTime = 0.8 * sequentialTime; + const double maxTime = 0.8*sequentialTime; var threadedWorker = new ThreadedWorker(); var stopwatch = new Stopwatch(); stopwatch.Start(); for (int i = 0; i < numWorkItems; i++) - threadedWorker.ProcessWorkItemAsync(()=>Thread.Sleep(timePerWorkItem)); + { + threadedWorker.ProcessWorkItemAsync(() => Thread.Sleep(timePerWorkItem)); + } threadedWorker.WaitTillAllWorkItemsDone(); @@ -56,11 +58,15 @@ var threadedWorker = new ThreadedWorker(); for (int i = 0; i < numWorkItems; i++) + { threadedWorker.ProcessWorkItemAsync(() => Thread.Sleep(timePerWorkItem)); + } threadedWorker.WaitTillAllWorkItemsDone(); for (int i = 0; i < numWorkItems; i++) + { threadedWorker.ProcessWorkItemAsync(() => Thread.Sleep(timePerWorkItem)); + } threadedWorker.WaitTillAllWorkItemsDone(); } }