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

feat add no args task test
Some checks failed
rpcrypto-build / build (Release, himix200.toolchain.cmake) (push) Successful in 57s
Details
rpcrypto-build / build (Debug, himix200.toolchain.cmake) (push) Successful in 1m2s
Details
rpcrypto-build / build (Debug, hisiv510.toolchain.cmake) (push) Successful in 1m6s
Details
rpcrypto-build / build (Release, hisiv510.toolchain.cmake) (push) Successful in 1m13s
Details
linux-mips64-gcc / linux-gcc-mips64el (push) Successful in 1m23s
Details
linux-x64-gcc / linux-gcc (push) Successful in 1m31s
Details
linux-hisiv500-gcc / linux-gcc-hisiv500 (push) Failing after 56s
Details

Browse Source
This commit is contained in:
tqcq 2024-01-02 17:38:35 +08:00
parent 59e5b6644a
commit c6a2dbac8d
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
tests/ulib/system/thread_pool_unittest.cpp
View File

@ -4,7 +4,10 @@
class ThreadPoolTest : public ::testing::Test {
protected:
void SetUp() override { thread_pool_ = std::make_unique<ulib::ThreadPool>(10); }
void SetUp() override
{
thread_pool_ = std::make_unique<ulib::ThreadPool>(10);
}
std::unique_ptr<ulib::ThreadPool> thread_pool_;
};
@ -32,3 +35,15 @@ TEST_F(ThreadPoolTest, MultiTask)
for (auto &future : futures) { ASSERT_EQ(future.get(), 3); }
}
TEST_F(ThreadPoolTest, NoArgs)
{
std::vector<std::future<int>> futures;
for (int i = 0; i < 1000; ++i) {
futures.emplace_back(thread_pool_->Submit([]() {
ulib::Thread::Sleep(1000);
return 1;
}));
}
for (auto &future : futures) { future.get(); }
}