TEST_F() [54/72]

SpicesTest::TEST_F	(	ThreadPoolCached_test	,
		SubmitVeryMuchAnyTask	)

Testing if submit very much mixed task successfully.

Definition at line 385 of file ThreadPoolCached_test.h.

                                                         {
 
        SPICESTEST_PROFILE_FUNCTION();
 
        auto func = []() -> void
        {
            std::this_thread::sleep_for(std::chrono::microseconds(1));
        };
        auto func1 = [](int sec) -> void
        {
            std::this_thread::sleep_for(std::chrono::microseconds(sec));
        };
 
        for (int i = 0; i < 5000; i++)
        {
            m_ThreadPool.SubmitPoolTask(func);
        }
 
        for (int i = 0; i < 1000; i++)
        {
            m_ThreadPool.SubmitThreadTask_LightWeight_ForEach(func);
        }
 
        /* @brief Wait for all tasks finish. */
        m_ThreadPool.Wait();
 
        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                         );
 
        for (auto& pair : m_ThreadPool.GetThreads())
        {
            EXPECT_EQ(pair.second->GetThreadTasksCount(), 0);
        }
 
        /* @brief Wait for all threads recovery. */
        while (m_ThreadPool.GetThreadsCount() != nThreads)
        {
            func1(1000);
        }
 
        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                         );
    }