1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
#include "catch.hpp"
#include <osmium/thread/queue.hpp>
TEST_CASE("Basic use of thread-safe queue") {
osmium::thread::Queue<int> queue;
REQUIRE(queue.empty());
queue.push(22);
REQUIRE_FALSE(queue.empty());
REQUIRE(queue.size() == 1);
int value = 0;
queue.wait_and_pop(value);
REQUIRE(value == 22);
REQUIRE(queue.empty());
}
TEST_CASE("Queue can have max elements and can be named") {
const osmium::thread::Queue<int> queue{100, "Queue of max size 100"};
}
TEST_CASE("When queue is shut down, nothing goes in or out") {
osmium::thread::Queue<std::string> queue;
REQUIRE(queue.in_use());
REQUIRE(queue.empty());
queue.push("foo");
queue.push("bar");
queue.push("baz");
REQUIRE(queue.size() == 3);
std::string value;
queue.wait_and_pop(value);
REQUIRE(value == "foo");
REQUIRE(queue.size() == 2);
REQUIRE(queue.in_use());
queue.shutdown();
REQUIRE_FALSE(queue.in_use());
REQUIRE(queue.empty());
queue.push("lost");
REQUIRE(queue.empty());
value.clear();
queue.try_pop(value);
REQUIRE(value.empty());
queue.wait_and_pop(value);
REQUIRE(value.empty());
}
|
