fix

src/multi-threaded/test/LockFreeForwardListTest.cpp

@@ -52,24 +52,26 @@ TEST(LockFreeListTest, concurrent_push) {
 
 TEST(LockFreeListTest, push_while_looping) {
   LockFreeForwardList<Person> list{"foo", "bla"};
-  std::size_t times = 50;
+  std::size_t insertions = 40;
 
-  std::atomic_bool producing = true;
-  std::size_t max_size = 0;
+  std::atomic_bool barrier = true;
+  std::size_t list_snapshot_size;
   ParallelRegion::execute(
       [&] {
-        for (std::size_t k = 0; k < times; ++k) {
+        for (std::size_t k = 0; k < insertions / 2; ++k) {
+          list.emplace_back("foo", "bla");
+        }
+        barrier = false;
+        for (std::size_t k = 0; k < insertions / 2; ++k) {
           list.emplace_back("foo", "bla");
         }
-        producing = false;
       },
       [&] {
-        while (producing.load()) {
-          std::size_t size = 0;
-          list.forEach([&](const Person &person) { ++size; });
-          max_size = std::max<std::size_t>(max_size, size);
+        while (barrier.load()) {
         }
+        std::size_t size = 0;
+        list.forEach([&](const Person &person) { ++list_snapshot_size; });
       });
 
-  EXPECT_TRUE(40 < max_size);
+  EXPECT_TRUE(insertions / 2 <= list_snapshot_size);
 }