Improve scan test

This commit is contained in:
Victor Zverovich 2023-12-29 08:22:55 -08:00
parent 662d784157
commit 4a6f0be5b6

View File

@ -152,6 +152,7 @@ TEST(scan_test, lock) {
write_end.close(); write_end.close();
}); });
std::atomic<int> count(0);
fmt::buffered_file f = read_end.fdopen("r"); fmt::buffered_file f = read_end.fdopen("r");
auto fun = [&]() { auto fun = [&]() {
int value = 0; int value = 0;
@ -161,12 +162,16 @@ TEST(scan_test, lock) {
EXPECT_EQ(value, 42); EXPECT_EQ(value, 42);
break; break;
} }
++count;
} }
}; };
std::thread consumer1(fun); std::thread consumer1(fun);
std::thread consumer2(fun); std::thread consumer2(fun);
producer.join(); producer.join();
consumer1.join(); consumer1.join();
consumer2.join(); consumer2.join();
EXPECT_EQ(count, 1000);
} }
#endif // FMT_USE_FCNTL #endif // FMT_USE_FCNTL