TEST_F() [66/72]

SpicesTest::TEST_F	(	ThreadPoolFixed_test	,
		SubmitTask_ReturnVal	)

Testing if submit task get correct blocked result successfully. With profermance test.

Definition at line 153 of file ThreadPoolFixed_test.h.

                                                       {
 
        SPICESTEST_PROFILE_FUNCTION();
 
        auto func = [](uint32_t a, uint32_t b) -> uint32_t
        {
            uint32_t val = 0;
            for (uint32_t i = a; i < b; i++)
            {
                val += i;
            }
            return val;
        };
 
        auto inTime = std::chrono::high_resolution_clock::now();
 
        std::future<uint32_t> future0 = m_ThreadPool.SubmitPoolTask(std::bind(func, 0        , 100000000));
        std::future<uint32_t> future1 = m_ThreadPool.SubmitPoolTask(std::bind(func, 100000000, 200000000));
        std::future<uint32_t> future2 = m_ThreadPool.SubmitPoolTask(std::bind(func, 200000000, 300000000));
        std::future<uint32_t> future3 = m_ThreadPool.SubmitPoolTask(std::bind(func, 300000000, 400000000));
        std::future<uint32_t> future4 = m_ThreadPool.SubmitPoolTask(std::bind(func, 400000000, 500000000));
 
        const uint32_t subThreadCalVal = future0.get() + future1.get() + future2.get() + future3.get() + future4.get();
 
        auto multiThreadTime = std::chrono::high_resolution_clock::now();
 
        std::cout << "Calculate with multiple thread cost: " << std::chrono::duration_cast<std::chrono::milliseconds>(multiThreadTime - inTime).count() << std::endl;
 
        inTime = std::chrono::high_resolution_clock::now();
 
        const uint32_t mainThreadCalVal = func(0, 500000000);
 
        multiThreadTime = std::chrono::high_resolution_clock::now();
 
        std::cout << "Calculate with main thread cost: " << std::chrono::duration_cast<std::chrono::milliseconds>(multiThreadTime - inTime).count() << std::endl;
 
        EXPECT_EQ(mainThreadCalVal, subThreadCalVal);
    }