1 #include "catch.hpp"
2 
3 #include <osmium/thread/queue.hpp>
4 
5 TEST_CASE("Basic use of thread-safe queue") {
6     osmium::thread::Queue<int> queue;
7     REQUIRE(queue.empty());
8     queue.push(22);
9     REQUIRE_FALSE(queue.empty());
10     REQUIRE(queue.size() == 1);
11     int value = 0;
12     queue.wait_and_pop(value);
13     REQUIRE(value == 22);
14     REQUIRE(queue.empty());
15 }
16 
17 TEST_CASE("Queue can have max elements and can be named") {
18     osmium::thread::Queue<int> queue{100, "Queue of max size 100"};
19 }
20 
21