Lines Matching refs:CommonPool
30 TEST(CommonPool, post) { in TEST() argument
32 CommonPool::post([&ran] { ran = true; }); in TEST()
45 futures[i] = CommonPool::async([] { in TEST()
53 EXPECT_EQ(threads.size(), CommonPool::THREAD_COUNT); in TEST()
57 TEST(CommonPool, singleThread) { in TEST() argument
63 auto f1 = CommonPool::async([&] { in TEST()
82 auto f2 = CommonPool::async([] { in TEST()
104 static constexpr auto QUEUE_COUNT = CommonPool::THREAD_COUNT + CommonPool::QUEUE_SIZE + 10; in TEST()
110 futures[i] = CommonPool::async([&] { in TEST()
126 EXPECT_GT(queuedCount.load(), CommonPool::QUEUE_SIZE); in TEST()
166 TEST(CommonPool, asyncLifecycleCheck) { in TEST() argument
171 EXPECT_LT(1, CommonPool::async([obj] { return ObjectTracker::count(); }).get()); in TEST()
173 CommonPool::waitForIdle(); in TEST()
177 TEST(CommonPool, syncLifecycleCheck) { in TEST() argument
182 EXPECT_LT(1, CommonPool::runSync([obj] { return ObjectTracker::count(); })); in TEST()
184 CommonPool::waitForIdle(); in TEST()