123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299 |
- #include "ceres/concurrent_queue.h"
- #include <chrono>
- #include <thread>
- #include "ceres/internal/config.h"
- #include "gmock/gmock.h"
- #include "gtest/gtest.h"
- namespace ceres::internal {
- TEST(ConcurrentQueue, PushPop) {
- ConcurrentQueue<int> queue;
- const int num_to_add = 10;
- for (int i = 0; i < num_to_add; ++i) {
- queue.Push(i);
- }
- for (int i = 0; i < num_to_add; ++i) {
- int value;
- ASSERT_TRUE(queue.Pop(&value));
- EXPECT_EQ(i, value);
- }
- }
- TEST(ConcurrentQueue, PushPopAfterStopWaiters) {
- ConcurrentQueue<int> queue;
- const int num_to_add = 10;
- int value;
-
- ASSERT_FALSE(queue.Pop(&value));
- for (int i = 0; i < num_to_add; ++i) {
- queue.Push(i);
- }
-
- queue.StopWaiters();
- for (int i = 0; i < num_to_add; ++i) {
- ASSERT_TRUE(queue.Pop(&value));
- EXPECT_EQ(i, value);
- }
-
- ASSERT_FALSE(queue.Pop(&value));
-
- const int offset = 123;
- for (int i = 0; i < num_to_add; ++i) {
- queue.Push(i + offset);
- }
- for (int i = 0; i < num_to_add; ++i) {
- int value;
- ASSERT_TRUE(queue.Pop(&value));
- EXPECT_EQ(i + offset, value);
- }
-
- ASSERT_FALSE(queue.Pop(&value));
-
- queue.StopWaiters();
- queue.Push(13456);
- ASSERT_TRUE(queue.Pop(&value));
- EXPECT_EQ(13456, value);
- }
- TEST(ConcurrentQueue, PushPopStopAndStart) {
- ConcurrentQueue<int> queue;
- int value;
- queue.Push(13456);
- queue.Push(256);
- queue.StopWaiters();
- ASSERT_TRUE(queue.Pop(&value));
- EXPECT_EQ(13456, value);
- queue.EnableWaiters();
-
- queue.Push(989);
-
- ASSERT_TRUE(queue.Pop(&value));
- EXPECT_EQ(256, value);
- ASSERT_TRUE(queue.Pop(&value));
- EXPECT_EQ(989, value);
-
- queue.EnableWaiters();
-
- ASSERT_FALSE(queue.Pop(&value));
- }
- TEST(ConcurrentQueue, Wait) {
- ConcurrentQueue<int> queue;
- int value;
- queue.Push(13456);
- ASSERT_TRUE(queue.Wait(&value));
- EXPECT_EQ(13456, value);
- queue.StopWaiters();
-
- EXPECT_FALSE(queue.Wait(&value));
- EXPECT_FALSE(queue.Wait(&value));
- EXPECT_FALSE(queue.Pop(&value));
-
- queue.StopWaiters();
- EXPECT_FALSE(queue.Wait(&value));
- EXPECT_FALSE(queue.Wait(&value));
- queue.Push(989);
- queue.Push(789);
- ASSERT_TRUE(queue.Wait(&value));
- EXPECT_EQ(989, value);
- ASSERT_TRUE(queue.Wait(&value));
- EXPECT_EQ(789, value);
- }
- TEST(ConcurrentQueue, EnsureWaitBlocks) {
- ConcurrentQueue<int> queue;
- int value = 0;
- bool valid_value = false;
- bool waiting = false;
- std::mutex mutex;
- std::thread thread([&]() {
- {
- std::lock_guard<std::mutex> lock(mutex);
- waiting = true;
- }
- int element = 87987;
- bool valid = queue.Wait(&element);
- {
- std::lock_guard<std::mutex> lock(mutex);
- waiting = false;
- value = element;
- valid_value = valid;
- }
- });
-
- std::this_thread::sleep_for(std::chrono::milliseconds(500));
-
- {
- std::lock_guard<std::mutex> lock(mutex);
- EXPECT_TRUE(waiting);
- ASSERT_FALSE(valid_value);
- ASSERT_EQ(0, value);
- }
- queue.Push(13456);
-
- thread.join();
- EXPECT_TRUE(valid_value);
- EXPECT_EQ(13456, value);
- }
- TEST(ConcurrentQueue, StopAndEnableWaiters) {
- ConcurrentQueue<int> queue;
- int value = 0;
- bool valid_value = false;
- bool waiting = false;
- std::mutex mutex;
- auto task = [&]() {
- {
- std::lock_guard<std::mutex> lock(mutex);
- waiting = true;
- }
- int element = 87987;
- bool valid = queue.Wait(&element);
- {
- std::lock_guard<std::mutex> lock(mutex);
- waiting = false;
- value = element;
- valid_value = valid;
- }
- };
- std::thread thread_1(task);
-
- std::this_thread::sleep_for(std::chrono::milliseconds(500));
-
- {
- std::lock_guard<std::mutex> lock(mutex);
- EXPECT_TRUE(waiting);
- }
-
- queue.StopWaiters();
- thread_1.join();
-
- EXPECT_FALSE(valid_value);
- EXPECT_EQ(87987, value);
-
- EXPECT_FALSE(queue.Wait(&value));
- queue.EnableWaiters();
- value = 0;
- valid_value = false;
- waiting = false;
-
- std::thread thread_2(task);
-
- std::this_thread::sleep_for(std::chrono::milliseconds(500));
-
- {
- std::lock_guard<std::mutex> lock(mutex);
- EXPECT_TRUE(waiting);
- ASSERT_FALSE(valid_value);
- ASSERT_EQ(0, value);
- }
- queue.Push(13456);
-
- thread_2.join();
- EXPECT_TRUE(valid_value);
- EXPECT_EQ(13456, value);
- }
- }
|