TEST_F() [55/72]

SpicesTest::TEST_F	(	ThreadPoolCached_test	,
		SubmitVeryMuchPoolTask	)

Testing if submit very much pool task successfully.

Definition at line 201 of file ThreadPoolCached_test.h.

                                                          {
 
        SPICESTEST_PROFILE_FUNCTION();
 
        auto func = [](int sec) -> bool
        {
            std::this_thread::sleep_for(std::chrono::microseconds(sec));
            return true;
        };
 
        std::vector<std::future<bool>> futures(10000);
        for (int i = 0; i < 10000; i++)
        {
            futures[i] = m_ThreadPool.SubmitPoolTask(std::bind(func, 1));
        }
 
        func(2000);  /* @brief Wait for part tasks finish. */
 
        EXPECT_EQ(m_ThreadPool.GetThreadsCount()     ,Spices::THREAD_MAX_THRESHHOLD);
 
        /* @brief Wait for all tasks finish. */
        for (int i = 0; i < 10000; i++)
        {
            futures[i].get(); 
        }
 
        EXPECT_EQ(m_ThreadPool.GetInitThreadSize()   ,nThreads                     );
        EXPECT_EQ(m_ThreadPool.GetIdleThreadSize()   ,Spices::THREAD_MAX_THRESHHOLD);
        EXPECT_EQ(m_ThreadPool.GetPoolMode()         ,Spices::PoolMode::MODE_CACHED);
        EXPECT_EQ(m_ThreadPool.GetTasks()            ,0                            );
        EXPECT_EQ(m_ThreadPool.GetThreadsCount()     ,Spices::THREAD_MAX_THRESHHOLD);
        EXPECT_EQ(m_ThreadPool.GetThreadIdleTimeOut(),10                           );
        EXPECT_EQ(m_ThreadPool.IsPoolRunning()       ,true                         );
 
        /* @brief Wait for all threads recovery. */
        auto inTime = std::chrono::high_resolution_clock::now();
        while (m_ThreadPool.GetThreadsCount() != nThreads) 
        {
            func(1000);
        }
        auto outTime = std::chrono::high_resolution_clock::now();
 
        std::cout << "Cache Mode recovery threads cost: " << std::chrono::duration_cast<std::chrono::milliseconds>(outTime - inTime).count() << std::endl;
 
        EXPECT_EQ(m_ThreadPool.GetInitThreadSize()   ,nThreads                     );
        EXPECT_EQ(m_ThreadPool.GetIdleThreadSize()   ,nThreads                     );
        EXPECT_EQ(m_ThreadPool.GetPoolMode()         ,Spices::PoolMode::MODE_CACHED);
        EXPECT_EQ(m_ThreadPool.GetTasks()            ,0                            );
        EXPECT_EQ(m_ThreadPool.GetThreadsCount()     ,nThreads                     );
        EXPECT_EQ(m_ThreadPool.GetThreadIdleTimeOut(),10                           );
        EXPECT_EQ(m_ThreadPool.IsPoolRunning()       ,true                         );
    }