tools::threadpool Class Reference

A global thread pool. More...

#include <threadpool.h>

Classes
class	waiter

Public Member Functions
void	submit (waiter *waiter, std::function< void()> f, bool leaf=false)
unsigned int	get_max_concurrency () const
	~threadpool ()

Static Public Member Functions
static threadpool &	getInstance ()
static threadpool *	getNewForUnitTests (unsigned max_threads=0)

Detailed Description

A global thread pool.

Definition at line 43 of file threadpool.h.

Constructor & Destructor Documentation

~threadpool()

tools::threadpool::~threadpool

(

)

Definition at line 49 of file threadpool.cpp.

                        {
  try
  {
    const boost::unique_lock<boost::mutex> lock(mutex);
    running = false;
    has_work.notify_all();
  }
  catch (...)
  {
    // if the lock throws, we're just do it without a lock and hope,
    // since the alternative is terminate
    running = false;
    has_work.notify_all();
  }
  for (size_t i = 0; i<threads.size(); i++) {
    try { threads[i].join(); }
    catch (...) { /* ignore */ }
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

get_max_concurrency()

unsigned int tools::threadpool::get_max_concurrency

(

)

const

Definition at line 92 of file threadpool.cpp.

                                                   {
  return max;
}

Here is the call graph for this function:

Here is the caller graph for this function:

getInstance()

threadpool & tools::threadpool::getInstance ( )

inlinestatic

Definition at line 46 of file threadpool.h.

                                   {
    static threadpool instance;
    return instance;
  }

Here is the caller graph for this function:

getNewForUnitTests()

threadpool * tools::threadpool::getNewForUnitTests ( unsigned max_threads = 0 )

inlinestatic

Definition at line 50 of file threadpool.h.

                                                                {
    return new threadpool(max_threads);
  }

Here is the caller graph for this function:

submit()

void tools::threadpool::submit	(	waiter *	waiter,
		std::function< void()>	f,
		bool	leaf = false )

Definition at line 69 of file threadpool.cpp.

                                                                     {
  CHECK_AND_ASSERT_THROW_MES(!is_leaf, "A leaf routine is using a thread pool");
  boost::unique_lock<boost::mutex> lock(mutex);
  if (!leaf && ((active == max && !queue.empty()) || depth > 0)) {
    // if all available threads are already running
    // and there's work waiting, just run in current thread
    lock.unlock();
    ++depth;
    is_leaf = leaf;
    f();
    --depth;
    is_leaf = false;
  } else {
    if (obj)
      obj->inc();
    if (leaf)
      queue.push_front({obj, f, leaf});
    else
      queue.push_back({obj, f, leaf});
    has_work.notify_one();
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

---

The documentation for this class was generated from the following files:

• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/src/common/threadpool.h
• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/src/common/threadpool.cpp