tqcq/tile
1
0
Fork 0
Code Issues Pull Requests Actions Projects 1 Releases Wiki Activity

feat add timeout
Some checks failed
ci/pr/linux-aarch64-gcc/1 Pipeline failed
Details
ci/push/linux-aarch64-gcc/1 Pipeline was successful
Details
ci/push/linux-x64-gcc/2 Pipeline failed
Details
ci/push/linux-aarch64-gcc/2 Pipeline failed
Details
ci/pr/linux-x64-gcc/1 Pipeline was successful
Details
ci/pr/linux-aarch64-gcc/2 Pipeline failed
Details
ci/push/linux-x64-gcc/1 Pipeline was successful
Details
ci/pr/linux-x64-gcc/2 Pipeline failed
Details

Browse Source
This commit is contained in:
tqcq 2024-08-11 10:49:31 +08:00
parent ef009a4ae9
commit 7b13e5584a
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tile/base/thread/cond_var_test.cc
View File

@ -36,8 +36,8 @@ class CondVarTest : public ::testing::Test {
protected:
Mutex *m;
CondVar *cv;
volatile bool is_set;
volatile bool is_timeout;
bool is_set;
bool is_timeout;
std::thread *worker;
};
@ -69,6 +69,7 @@ TEST_F(CondVarTest, NotifyOne_Wait) {
TEST_F(CondVarTest, NotifyOne_WaitFor) {
// Wait
// constexpr auto kWaitTimeoutMs = 100;
auto start = ReadSteadyClock();
constexpr auto kWaitTimeout = std::chrono::milliseconds(50);
auto WaitFor = [&] {
UniqueLock<Mutex> inner_locker(*m);
@ -91,9 +92,16 @@ TEST_F(CondVarTest, NotifyOne_WaitFor) {
cv->NotifyOne();
}
auto now = ReadSteadyClock();
t1.join();
ASSERT_TRUE(is_set);
if (now - start > kWaitTimeout) {
// timeout
ASSERT_TRUE(is_timeout);
ASSERT_FALSE(is_set);
} else {
ASSERT_FALSE(is_timeout);
ASSERT_TRUE(is_set);
}
}
// timeout