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