TestExecutorTest.cpp File Reference

#include <folly/futures/test/TestExecutor.h>
#include <folly/portability/GTest.h>

Go to the source code of this file.

Functions
	TEST (TestExecutor, parallel_run)

Function Documentation

TEST	(	TestExecutor	,
		parallel_run
	)

Definition at line 24 of file TestExecutorTest.cpp.

References folly::pushmi::executor, EXPECT_EQ, m, and mutex.

                                 {
  mutex m;
  set<thread::id> ids;
  auto executor = std::make_unique<TestExecutor>(4);
  const auto numThreads = executor->numThreads();
  EXPECT_EQ(4, numThreads);
  for (auto idx = 0U; idx < numThreads * 10; ++idx) {
    executor->add([&m, &ids]() mutable {
      /* sleep override */ this_thread::sleep_for(milliseconds(100));
      lock_guard<mutex> lg(m);
      ids.insert(this_thread::get_id());
    });
  }

  executor = nullptr;
  EXPECT_EQ(ids.size(), numThreads);
}