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

feat add thread_pool test case
Some checks failed
linux-mips64-gcc / linux-gcc-mips64el (Release) (push) Successful in 2m22s
Details
linux-x64-gcc / linux-gcc (Debug) (push) Failing after 1m24s
Details
linux-x64-gcc / linux-gcc (Release) (push) Failing after 1m21s
Details
linux-mips64-gcc / linux-gcc-mips64el (Debug) (push) Successful in 4m3s
Details

Browse Source
This commit is contained in:
tqcq 2024-03-31 22:16:53 +08:00
parent a711d6bfb4
commit 9444c23db2
2 changed files with 38 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/sled/synchronization/event.h
View File

@ -18,7 +18,7 @@ public:
static constexpr TimeDelta kForever = ConditionVariable::kForever;
Event();
Event(bool manual_reset, bool initially_signaled);
Event(const Event &) = delete;
Event(const Event &) = delete;
Event &operator=(const Event &) = delete;
~Event();

52
src/sled/system/thread_pool_test.cc
View File

@ -1,4 +1,5 @@
#include <random>
#include <sled/synchronization/event.h>
#include <sled/system/thread_pool.h>
std::random_device rd;
@ -37,26 +38,47 @@ multiply_return(const int a, const int b)
return res;
}
TEST_CASE("ThreadPool")
TEST_SUITE("ThreadPool")
{
sled::ThreadPool *tp = new sled::ThreadPool();
REQUIRE_NE(tp, nullptr);
TEST_CASE("submit")
{
sled::ThreadPool *tp = new sled::ThreadPool();
REQUIRE_NE(tp, nullptr);
SUBCASE("Output")
{
for (int i = 0; i < 100; ++i) {
int out;
tp->submit(multiply_output, std::ref(out), i, i).get();
CHECK_EQ(out, i * i);
SUBCASE("Output")
{
for (int i = 0; i < 100; ++i) {
int out;
tp->submit(multiply_output, std::ref(out), i, i).get();
CHECK_EQ(out, i * i);
}
}
SUBCASE("Return")
{
for (int i = 0; i < 100; ++i) {
auto f = tp->submit(multiply_return, i, i);
CHECK_EQ(f.get(), i * i);
}
}
delete tp;
}
SUBCASE("Return")
TEST_CASE("PostTask")
{
for (int i = 0; i < 100; ++i) {
auto f = tp->submit(multiply_return, i, i);
CHECK_EQ(f.get(), i * i);
}
sled::ThreadPool *tp = new sled::ThreadPool();
sled::Event waiter;
tp->PostTask([&]() { waiter.Set(); });
CHECK(waiter.Wait(sled::TimeDelta::Seconds(1)));
delete tp;
}
delete tp;
TEST_CASE("PostDelayedTask")
{
sled::ThreadPool *tp = new sled::ThreadPool();
sled::Event waiter;
tp->PostDelayedTask([&]() { waiter.Set(); }, sled::TimeDelta::Millis(100));
CHECK_FALSE(waiter.Wait(sled::TimeDelta::Millis(50)));
CHECK(waiter.Wait(sled::TimeDelta::Millis(150)));
delete tp;
}
}