Function TEST

tests/query/parallel_executor_test.cc:32–53

const int kMillSeconds = 100;

TEST(SchedulerTest, TestScheduler) {
  SchedulerPtr scheduler = Scheduler::Default();
  uint32_t concurrency = Scheduler::HostConcurrency();
  ASSERT_EQ(scheduler->concurrency(concurrency), concurrency);

  ExecutorPtr executor = ExecutorPtr(new ParallelExecutor(scheduler));

  TaskPtr task = CreateTask(kName, kCode, kMillSeconds);
  TaskPtr task2 = CreateTask(kName, kCode, kMillSeconds);

  // invoke task->run in current routine
  ASSERT_EQ(executor->execute_task(task), kCode);

  ASSERT_TRUE(task->finished());

  TaskPtrList tasks = {task2, CreateTask(kName, kCode, kMillSeconds),
                       CreateTask(kName, kCode, kMillSeconds)};

  executor->execute_tasks(tasks);

  ASSERT_TRUE(task2->finished());
}