ThreadedRepeatingFunctionRunnerTest.cpp File Reference

#include <folly/experimental/ThreadedRepeatingFunctionRunner.h>
#include <folly/portability/GTest.h>
#include <atomic>

Go to the source code of this file.

Classes
class	Foo
struct	FooLongSleep

Functions
	TEST (TestThreadedRepeatingFunctionRunner, HandleBackgroundLoop)
	TEST (TestThreadedRepeatingFunctionRunner, HandleLongSleepingThread)

Function Documentation

TEST	(	TestThreadedRepeatingFunctionRunner	,
		HandleBackgroundLoop
	)

Definition at line 58 of file ThreadedRepeatingFunctionRunnerTest.cpp.

References data, EXPECT_EQ, and f.

                                                                {
  std::atomic<int> data(0);
  {
    Foo f(data);
    EXPECT_EQ(0, data.load());
    f.start(); // Runs increment thread in background
    while (data.load() == 0) {
      /* sleep override */ this_thread::sleep_for(chrono::milliseconds(10));
    }
  }
  // The increment thread should have been destroyed
  auto prev_val = data.load();
  /* sleep override */ this_thread::sleep_for(chrono::milliseconds(100));
  EXPECT_EQ(data.load(), prev_val);
}

TEST	(	TestThreadedRepeatingFunctionRunner	,
		HandleLongSleepingThread
	)

Definition at line 74 of file ThreadedRepeatingFunctionRunnerTest.cpp.

References data, EXPECT_EQ, f, and FooLongSleep::start().

                                                                    {
  std::atomic<int> data(0);
  {
    FooLongSleep f(data);
    EXPECT_EQ(0, data.load());
    f.start();
    while (data.load() == 0) {
      /* sleep override */ this_thread::sleep_for(chrono::milliseconds(10));
    }
    EXPECT_EQ(1, data.load());
  }
  // Foo should have been destroyed, which stopped the thread!
  EXPECT_EQ(-1, data.load());
}