FM / thread

/srv/osrm/osrm-backend/third_party/libosmium/test/t/thread/

/srv/osrm/osrm-backend/third_party/libosmium/test/t/thread

Name	Size	Mode	Actions
test_pool.cpp	3641	0644	edit dl rm
test_queue.cpp	1179	0644	edit dl rm
test_util.cpp	1389	0644	edit dl rm

Edit: /srv/osrm/osrm-backend/third_party/libosmium/test/t/thread/test_queue.cpp (1179B)

#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") {
    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());
}

cmd: