ref: 122d6a9f15f9bc46b295c0ccd66eb361ea2e897a
dir: /test/common/WelsTaskListTest.cpp/
#include <gtest/gtest.h> #include <string.h> #include <string> #include <list> #include <map> #include "typedefs.h" #include "WelsList.h" #include "WelsTask.h" #include "WelsThreadPoolTest.h" TEST (CThreadPoolTest, CThreadPoolTest_List) { CWelsList<IWelsTask>* pTaskList; pTaskList = new CWelsList<IWelsTask>(); ASSERT_TRUE(NULL != pTaskList); CThreadPoolTest cThreadPoolTest; CThreadPoolTest cThreadPoolTest1; CSimpleTask* aTasks[2] = {NULL, NULL}; IWelsTask* pCurTask; int32_t i; aTasks[0] = new CSimpleTask (&cThreadPoolTest); aTasks[1] = new CSimpleTask (&cThreadPoolTest1); pTaskList->push_back(aTasks[0]); pTaskList->push_back(aTasks[1]); EXPECT_TRUE(2 == pTaskList->size()); pCurTask = pTaskList->begin(); EXPECT_TRUE(pCurTask->GetSink() == &cThreadPoolTest); pCurTask->GetSink()->OnTaskExecuted();//cThreadPoolTest pTaskList->pop_front(); EXPECT_TRUE(1 == pTaskList->size()); pCurTask = pTaskList->begin(); EXPECT_TRUE(pCurTask->GetSink() == &cThreadPoolTest1); pCurTask->GetSink()->OnTaskExecuted();//cThreadPoolTest1 pTaskList->pop_front(); pTaskList->push_back(aTasks[1]); EXPECT_TRUE(1 == pTaskList->size()); pCurTask = pTaskList->begin(); EXPECT_TRUE(pCurTask->GetSink() == &cThreadPoolTest1); pCurTask->GetSink()->OnTaskExecuted();//cThreadPoolTest1 pTaskList->pop_front(); EXPECT_TRUE(1 == cThreadPoolTest.GetTaskCount()); EXPECT_TRUE(2 == cThreadPoolTest1.GetTaskCount()); EXPECT_TRUE(0 == pTaskList->size()); for (i = 0; i < 2; i++) { delete aTasks[i]; aTasks[i] = NULL; } aTasks[0] = new CSimpleTask (&cThreadPoolTest1); aTasks[1] = new CSimpleTask (&cThreadPoolTest); pTaskList->push_back(aTasks[0]); pTaskList->push_back(aTasks[1]); pCurTask = pTaskList->begin(); EXPECT_TRUE(pCurTask->GetSink() == &cThreadPoolTest1); pCurTask->GetSink()->OnTaskExecuted();//cThreadPoolTest1:3 pTaskList->pop_front(); EXPECT_TRUE(1 == pTaskList->size()); pTaskList->push_back(aTasks[0]); EXPECT_TRUE(2 == pTaskList->size()); pCurTask = pTaskList->begin(); EXPECT_TRUE(pCurTask->GetSink() == &cThreadPoolTest); pCurTask->GetSink()->OnTaskExecuted();//cThreadPoolTest:2 pTaskList->pop_front(); pCurTask = pTaskList->begin(); EXPECT_TRUE(pCurTask->GetSink() == &cThreadPoolTest1); pCurTask->GetSink()->OnTaskExecuted();//cThreadPoolTest1:4 pTaskList->pop_front(); EXPECT_TRUE(2 == cThreadPoolTest.GetTaskCount()); EXPECT_TRUE(4 == cThreadPoolTest1.GetTaskCount()); for (i = 0; i < 2; i++) { delete aTasks[i]; aTasks[i] = NULL; } delete pTaskList; }