Function TEST

test/concurrent/test_execution_queue.cpp:15–29

using Iterator = Queue::Iterator;

TEST(concurrent_execution_queue, initialize_reserve_queue_capacity) {
  ConcurrentExecutionQueue<::std::string> queue;
  auto ret = queue.initialize(2, AlwaysUseNewThreadExecutor::instance(),
                              [](Iterator, Iterator) {});
  ASSERT_EQ(0, ret);
  ASSERT_EQ(2, queue.capacity());
  ret = queue.initialize(5, AlwaysUseNewThreadExecutor::instance(),
                         [](Iterator, Iterator) {});
  ASSERT_EQ(0, ret);
  ASSERT_EQ(8, queue.capacity());
  ret = queue.initialize(8, AlwaysUseNewThreadExecutor::instance(),
                         [](Iterator, Iterator) {});
  ASSERT_EQ(0, ret);
  ASSERT_EQ(8, queue.capacity());
}

TEST(concurrent_execution_queue, execute_submit_execute_async_but_serially) {
  ConcurrentExecutionQueue<::std::string> queue;