Function TEST

test/common/WelsTaskListTest.cpp:13–90

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]);