mirror of
https://github.com/LadybirdBrowser/ladybird.git
synced 2024-11-11 01:06:01 +03:00
086316057b
The threading tests currently wait for a very small amount of time for
the expected test condition to be reached, e.g. 20ms. This changes the
tests to *check* the condition every 20ms, but allow the test to run for
up to 2s until the condition is reached. This should hopefully resolve
the failures seen on CI.
This also renames one of the tests to match what it actually does. The
test itself was changed in commit 5b335e7, but the name was not updated
to reflect that change.
74 lines
1.9 KiB
C++
74 lines
1.9 KiB
C++
/*
|
|
* Copyright (c) 2021, Spencer Dixon <spencercdixon@gmail.com>
|
|
*
|
|
* SPDX-License-Identifier: BSD-2-Clause
|
|
*/
|
|
|
|
#include <AK/Time.h>
|
|
#include <LibTest/TestCase.h>
|
|
#include <LibThreading/Thread.h>
|
|
#include <unistd.h>
|
|
|
|
using namespace AK::TimeLiterals;
|
|
|
|
static void sleep_until_thread_exits(Threading::Thread const& thread)
|
|
{
|
|
static constexpr auto delay = 20_ms;
|
|
|
|
for (auto i = 0; i < 100; ++i) {
|
|
if (thread.has_exited())
|
|
return;
|
|
|
|
usleep(delay.to_microseconds());
|
|
}
|
|
|
|
FAIL("Timed out waiting for thread to exit");
|
|
}
|
|
|
|
TEST_CASE(threads_can_detach)
|
|
{
|
|
Atomic<int> should_be_42 = 0;
|
|
|
|
auto thread = Threading::Thread::construct([&should_be_42]() {
|
|
usleep(10 * 1000);
|
|
should_be_42 = 42;
|
|
return 0;
|
|
});
|
|
thread->start();
|
|
thread->detach();
|
|
|
|
sleep_until_thread_exits(*thread);
|
|
EXPECT(should_be_42 == 42);
|
|
}
|
|
|
|
TEST_CASE(detached_threads_do_not_need_to_be_joined)
|
|
{
|
|
Atomic<bool> should_exit { false };
|
|
auto thread = Threading::Thread::construct([&]() {
|
|
while (!should_exit.load())
|
|
usleep(10 * 1000);
|
|
return 0;
|
|
});
|
|
thread->start();
|
|
thread->detach();
|
|
|
|
// Because of how the crash test forks and removes the thread, we can't use that to verify that join() crashes. Instead, we check the join crash condition ourselves.
|
|
EXPECT(!thread->needs_to_be_joined());
|
|
|
|
// FIXME: Dropping a running thread crashes because of the Function destructor. For now, force the detached thread to exit.
|
|
should_exit.store(true);
|
|
sleep_until_thread_exits(*thread);
|
|
}
|
|
|
|
TEST_CASE(join_dead_thread)
|
|
{
|
|
auto thread = Threading::Thread::construct([&]() { return 0 /*nullptr*/; });
|
|
thread->start();
|
|
|
|
// The thread should have exited by then.
|
|
sleep_until_thread_exits(*thread);
|
|
|
|
auto join_result = TRY_OR_FAIL(thread->join<int*>());
|
|
EXPECT_EQ(join_result, static_cast<int*>(0));
|
|
}
|