tools::threadpool::waiter Class Reference

#include <threadpool.h>

Public Member Functions
void	inc ()
void	dec ()
void	wait (threadpool *tpool)
	waiter ()
	Wait for a set of tasks to finish.
	~waiter ()

Detailed Description

Definition at line 56 of file threadpool.h.

Constructor & Destructor Documentation

waiter()

tools::threadpool::waiter::waiter ( )

inline

Wait for a set of tasks to finish.

Definition at line 64 of file threadpool.h.

: num(0){}

~waiter()

tools::threadpool::waiter::~waiter

(

)

Definition at line 96 of file threadpool.cpp.

{
  try
  {
    boost::unique_lock<boost::mutex> lock(mt);
    if (num)
      MERROR("wait should have been called before waiter dtor - waiting now");
  }
  catch (...) { /* ignore */ }
  try
  {
    wait(NULL);
  }
  catch (const std::exception &e)
  {
    /* ignored */
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

dec()

void tools::threadpool::waiter::dec

(

)

Definition at line 128 of file threadpool.cpp.

                           {
  const boost::unique_lock<boost::mutex> lock(mt);
  num--;
  if (!num)
    cv.notify_all();
}

Here is the call graph for this function:

Here is the caller graph for this function:

inc()

void tools::threadpool::waiter::inc

(

)

Definition at line 123 of file threadpool.cpp.

                           {
  const boost::unique_lock<boost::mutex> lock(mt);
  num++;
}

Here is the call graph for this function:

Here is the caller graph for this function:

wait()

void tools::threadpool::waiter::wait

(

threadpool *

tpool

)

Definition at line 115 of file threadpool.cpp.

                                             {
  if (tpool)
    tpool->run(true);
  boost::unique_lock<boost::mutex> lock(mt);
  while(num)
    cv.wait(lock);
}

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