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()
59 TEST(CommonPool, DISABLED_singleThread) { in TEST() argument
65 auto f1 = CommonPool::async([&] { in TEST()
84 auto f2 = CommonPool::async([] { in TEST()
106 static constexpr auto QUEUE_COUNT = CommonPool::THREAD_COUNT + CommonPool::QUEUE_SIZE + 10; in TEST()
112 futures[i] = CommonPool::async([&] { in TEST()
128 EXPECT_GT(queuedCount.load(), CommonPool::QUEUE_SIZE); in TEST()
168 TEST(CommonPool, asyncLifecycleCheck) { in TEST() argument
173 EXPECT_LT(1, CommonPool::async([obj] { return ObjectTracker::count(); }).get()); in TEST()
175 CommonPool::waitForIdle(); in TEST()
179 TEST(CommonPool, syncLifecycleCheck) { in TEST() argument
184 EXPECT_LT(1, CommonPool::runSync([obj] { return ObjectTracker::count(); })); in TEST()
186 CommonPool::waitForIdle(); in TEST()