TEST_F() [46/72]

SpicesTest::TEST_F	(	ThreadPoolCached_test	,
		ContinueSuspend	)

Testing Continue/Suspend API.

Definition at line 442 of file ThreadPoolCached_test.h.

                                                   {
 
        SPICESTEST_PROFILE_FUNCTION();
 
        m_ThreadPool.Suspend();
 
        std::atomic_int executeCount;
 
        {
            SPICESTEST_PROFILE_SCOPE("Quick Task");
 
            for (int i = 0; i < 10; i++)
            {
                m_ThreadPool.SubmitPoolTask([&]() {
                    ++executeCount;
                });
            }
 
            EXPECT_EQ(m_ThreadPool.GetIdleThreadSize(), 10);
            EXPECT_EQ(m_ThreadPool.GetTasks(), 10);
 
            m_ThreadPool.Continue();
 
            m_ThreadPool.Wait();
            m_ThreadPool.Suspend();
 
            EXPECT_EQ(m_ThreadPool.GetIdleThreadSize(), 10);
            EXPECT_EQ(m_ThreadPool.GetTasks(), 0);
            EXPECT_EQ(executeCount.load(), 10);
        }
 
        {
            SPICESTEST_PROFILE_SCOPE("Slow Task");
 
            for (int i = 0; i < 10; i++)
            {
                m_ThreadPool.SubmitPoolTask([&]() {
                    std::this_thread::sleep_for(std::chrono::seconds(2));
                    ++executeCount;
                });
            }
 
            EXPECT_EQ(m_ThreadPool.GetIdleThreadSize(), 10);
            EXPECT_EQ(m_ThreadPool.GetTasks(), 10);
 
            m_ThreadPool.Continue();
            std::this_thread::sleep_for(std::chrono::seconds(1));
            m_ThreadPool.Suspend();
            std::this_thread::sleep_for(std::chrono::seconds(2));
 
            EXPECT_EQ(m_ThreadPool.GetIdleThreadSize(), 10);
            EXPECT_EQ(m_ThreadPool.GetTasks(), 0);
            EXPECT_EQ(executeCount.load(), 20);
 
            m_ThreadPool.Continue();
            m_ThreadPool.Wait();
 
            EXPECT_EQ(m_ThreadPool.GetIdleThreadSize(), 10);
            EXPECT_EQ(m_ThreadPool.GetTasks(), 0);
            EXPECT_EQ(executeCount.load(), 20);
        }
    }