threadpool.cpp File Reference

#include <atomic>
#include "gtest/gtest.h"
#include "misc_language.h"
#include "common/threadpool.h"

Include dependency graph for threadpool.cpp:

Go to the source code of this file.

Functions
	TEST (threadpool, wait_nothing)
	TEST (threadpool, wait_waits)
	TEST (threadpool, one_thread)
	TEST (threadpool, many_threads)
	TEST (threadpool, reentrency)
	TEST (threadpool, reentrancy)
	TEST (threadpool, leaf_throws)
	TEST (threadpool, leaf_reentrancy)

Function Documentation

TEST() [1/8]

TEST	(	threadpool	,
		leaf_reentrancy	)

Definition at line 127 of file threadpool.cpp.

{
  std::shared_ptr<tools::threadpool> tpool(tools::threadpool::getNewForUnitTests(4));
  tools::threadpool::waiter waiter;
 
  std::atomic<int> counter(0);
  for (int i = 0; i < 1000; ++i)
  {
    tpool->submit(&waiter, [&](){
      tools::threadpool::waiter waiter;
      for (int j = 0; j < 500; ++j)
      {
        tpool->submit(&waiter, [&](){ ++counter; }, true);
      }
      waiter.wait(tpool.get());
    });
  }
  waiter.wait(tpool.get());
  ASSERT_EQ(counter, 500000);
}

Here is the call graph for this function:

TEST() [2/8]

TEST	(	threadpool	,
		leaf_throws	)

Definition at line 112 of file threadpool.cpp.

{
  std::shared_ptr<tools::threadpool> tpool(tools::threadpool::getNewForUnitTests());
  tools::threadpool::waiter waiter;
 
  bool thrown = false, executed = false;
  tpool->submit(&waiter, [&](){
    try { tpool->submit(&waiter, [&](){ executed = true; }); }
    catch(const std::exception &e) { thrown = true; }
  }, true);
  waiter.wait(tpool.get());
  ASSERT_TRUE(thrown);
  ASSERT_FALSE(executed);
}

Here is the call graph for this function:

TEST() [3/8]

TEST	(	threadpool	,
		many_threads	)

Definition at line 66 of file threadpool.cpp.

{
  std::shared_ptr<tools::threadpool> tpool(tools::threadpool::getNewForUnitTests(256));
  tools::threadpool::waiter waiter;
 
  std::atomic<unsigned int> counter(0);
  for (size_t n = 0; n < 4096; ++n)
  {
    tpool->submit(&waiter, [&counter](){++counter;});
  }
  waiter.wait(tpool.get());
  ASSERT_EQ(counter, 4096);
}

Here is the call graph for this function:

TEST() [4/8]

TEST	(	threadpool	,
		one_thread	)

Definition at line 52 of file threadpool.cpp.

{
  std::shared_ptr<tools::threadpool> tpool(tools::threadpool::getNewForUnitTests(1));
  tools::threadpool::waiter waiter;
 
  std::atomic<unsigned int> counter(0);
  for (size_t n = 0; n < 4096; ++n)
  {
    tpool->submit(&waiter, [&counter](){++counter;});
  }
  waiter.wait(tpool.get());
  ASSERT_EQ(counter, 4096);
}

Here is the call graph for this function:

TEST() [5/8]

TEST	(	threadpool	,
		reentrancy	)

Definition at line 102 of file threadpool.cpp.

{
  std::shared_ptr<tools::threadpool> tpool(tools::threadpool::getNewForUnitTests(4));
  tools::threadpool::waiter waiter;
 
  uint64_t f = fibonacci(tpool, 13);
  waiter.wait(tpool.get());
  ASSERT_EQ(f, 233);
}

Here is the call graph for this function:

TEST() [6/8]

TEST	(	threadpool	,
		reentrency	)

Definition at line 92 of file threadpool.cpp.

{
  std::shared_ptr<tools::threadpool> tpool(tools::threadpool::getNewForUnitTests(4));
  tools::threadpool::waiter waiter;
 
  uint64_t f = fibonacci(tpool, 13);
  waiter.wait(tpool.get());
  ASSERT_EQ(f, 233);
}

Here is the call graph for this function:

TEST() [7/8]

TEST	(	threadpool	,
		wait_nothing	)

Definition at line 34 of file threadpool.cpp.

{
  std::shared_ptr<tools::threadpool> tpool(tools::threadpool::getNewForUnitTests());
  tools::threadpool::waiter waiter;
  waiter.wait(tpool.get());
}

Here is the call graph for this function:

TEST() [8/8]

TEST	(	threadpool	,
		wait_waits	)

Definition at line 41 of file threadpool.cpp.

{
  std::shared_ptr<tools::threadpool> tpool(tools::threadpool::getNewForUnitTests());
  tools::threadpool::waiter waiter;
  std::atomic<bool> b(false);
  tpool->submit(&waiter, [&b](){ epee::misc_utils::sleep_no_w(1000); b = true; });
  ASSERT_FALSE(b);
  waiter.wait(tpool.get());
  ASSERT_TRUE(b);
}

Here is the call graph for this function: