Test waiting on full channel

Author: andreiavrammsd

.github/workflows/cmake.yml

@@ -102,11 +102,11 @@ jobs:
 
       - name: Build
         working-directory: ${{github.workspace}}/build
-        run: cmake --build . --config Debug --target tests
+        run: cmake --build . --config Debug --target tests -j
 
       - name: Test
         working-directory: ${{github.workspace}}/build
-        run: ctest -C Debug --verbose -R channel_test
+        run: ctest -C Debug --verbose -R channel_test -j
 
       - name: Upload coverage reports to Codecov
         uses: codecov/codecov-action@v5

tests/channel_test.cpp

@@ -148,9 +148,9 @@ TEST(ChannelTest, Iterator)
 
 TEST(ChannelTest, Multithreading)
 {
-    const int numbers = 10000;
-    const std::int64_t expected = 50005000;
-    constexpr std::size_t kThreadsToReadFrom = 100;
+    const int numbers = 1000;
+    const std::int64_t expected = 500500;
+    constexpr std::size_t kThreadsToReadFrom = 50;
 
     msd::channel<int> channel{10};
 
@@ -176,6 +176,8 @@ TEST(ChannelTest, Multithreading)
 
             sum_numbers += out;
             ++count_numbers;
+
+            std::this_thread::sleep_for(std::chrono::milliseconds(1));
         }
         --wait_counter;
         cond_wait.notify_one();
@@ -186,16 +188,19 @@ TEST(ChannelTest, Multithreading)
         threads.emplace_back(std::thread{worker});
     }
 
-    // Send numbers to channel
-    for (int i = 1; i <= numbers; ++i) {
-        channel << i;
+    auto sender = [&] {
+        // Send numbers to channel
+        for (int i = 1; i <= numbers; ++i) {
+            channel << i;
 
-        // Notify threads than then can start reading
-        if (!ready_to_read) {
-            ready_to_read = true;
-            cond_read.notify_all();
+            // Notify threads than then can start reading
+            if (!ready_to_read) {
+                ready_to_read = true;
+                cond_read.notify_all();
+            }
         }
-    }
+    };
+    threads.emplace_back(std::thread{sender});
 
     // Wait until all items have been read
     std::unique_lock<std::mutex> lock{mtx_wait};