summaryrefslogtreecommitdiff
path: root/test/buildtool/multithreading/task_system.test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'test/buildtool/multithreading/task_system.test.cpp')
-rw-r--r--test/buildtool/multithreading/task_system.test.cpp13
1 files changed, 5 insertions, 8 deletions
diff --git a/test/buildtool/multithreading/task_system.test.cpp b/test/buildtool/multithreading/task_system.test.cpp
index 21e1ca6e..d34e3e4b 100644
--- a/test/buildtool/multithreading/task_system.test.cpp
+++ b/test/buildtool/multithreading/task_system.test.cpp
@@ -174,14 +174,11 @@ TEST_CASE("All threads run until work is done", "[task_system]") {
// Wait some time for all threads to go to sleep.
std::this_thread::sleep_for(1s);
- // Run singe task that creates the actual store tasks. All threads
- // should stay alive until their corresponding queue is filled.
- ts.QueueTask([&ts, &store_id] {
- // One task per thread (assumes round-robin push to queues).
- for (std::size_t i{}; i < ts.NumberOfThreads(); ++i) {
- ts.QueueTask([&store_id] { store_id(); });
- }
- });
+ // All threads should stay alive until their corresponding queue is
+ // filled. One task per thread (assumes round-robin push to queues).
+ for (std::size_t i{}; i < ts.NumberOfThreads(); ++i) {
+ ts.QueueTask([&store_id] { store_id(); });
+ }
}
CHECK(tids.size() == kNumThreads);
}