Function TEST

test/ThreadSafeQueueTest.cpp:67–94

________________________________________________________________

// ________________________________________________________________
TEST(ThreadSafeQueue, BufferSizeIsRespected) {
  auto runTest = [](auto queue) {
    std::atomic<size_t> numPushed = 0;
    auto push = makePush(queue);

    // Asynchronous worker thread that pushes incremental values to the queue.
    ad_utility::JThread t([&numPushed, &push, &queue] {
      while (numPushed < numValues) {
        push(numPushed++);
      }
      queue.finish();
    });

    size_t numPopped = 0;
    while (auto opt = queue.pop()) {
      // We have only one thread pushing, so the elements in the queue are
      // ordered.
      EXPECT_EQ(opt.value(), numPopped);
      ++numPopped;
      // Check that the size of the queue is respected. The pushing thread must
      // only continue to push once enough elements have been `pop`ped. The `+1`
      // is necessary because the calls to `pop` and `push` are not synchronized
      // with the atomic value `numPushed`.
      EXPECT_LE(numPushed, numPopped + queueSize + 1);
    }
  };
  runWithBothQueueTypes(runTest);
}

// _______________________________________________________________
TEST(ThreadSafeQueue, ReturnValueOfPush) {