3#include <catch2/catch_all.hpp>
5TEST_CASE(
"SafeQueue<T>::done())",
"[SafeQueue]")
9 queue.producerFinished();
17 for(
size_t i = 0; i < 3; ++i) {
19 CHECK(queue.size() == i);
21 CHECK(queue.size() == i + 1);
27 for(
size_t i = 0; i < 3; ++i) {
31 CHECK(queue.size() == 2 - i);
A thread-safe, optionally bounded queue with blocking push and pop operations.
Thread-safe queue implementation with optional bounded capacity.
CHECK(m.identifier==identifier)
CHECK_FALSE(m.hasDouble())
TEST_CASE("SafeQueue<T>::done())", "[SafeQueue]")