ThreadPool< TWorkItem, TFunctor > Class Template Reference

#include <threads.h>

Public Member Functions
	ThreadPool (TFunctor f, int Nthreads=-1)
	~ThreadPool ()
void	ProcessArray (TWorkItem *items, int n)
void	AddWork (TWorkItem w)
void	WaitUntilDone ()
bool	IsDone ()
void	Quit ()

Protected Member Functions
void	ItemDone ()
bool	GetNewItem (TWorkItem &item)

Static Protected Member Functions
static void	ThreadEntryPoint (void *param)

Protected Attributes
std::vector< Threads::Handle * >	threads
Threads::Mutex	workMutex
std::list< TWorkItem >	work
int	inProgress
Atomic< bool >	quit
TFunctor	worker

Detailed Description

template<typename TWorkItem, typename TFunctor>
class ThreadPool< TWorkItem, TFunctor >

Definition at line 177 of file threads.h.

Constructor & Destructor Documentation

ThreadPool()

template<typename TWorkItem, typename TFunctor>

ThreadPool< TWorkItem, TFunctor >::ThreadPool ( TFunctor  f, int  Nthreads = -1  )

inline

Definition at line 179 of file threads.h.

                                            : worker(f) {
        if (Nthreads<0) 
            Nthreads = Threads::GetCPUCount();
        threads.resize(Nthreads);
        quit=false;
        inProgress=0;
        for (int i=0;i<Nthreads;i++)
            threads[i]=Threads::Create(&ThreadEntryPoint,this);
    }

~ThreadPool()

template<typename TWorkItem, typename TFunctor>

ThreadPool< TWorkItem, TFunctor >::~ThreadPool ( )

inline

Definition at line 188 of file threads.h.

                  {
        Quit();
    }

Member Function Documentation

AddWork()

template<typename TWorkItem, typename TFunctor>

void ThreadPool< TWorkItem, TFunctor >::AddWork ( TWorkItem  w )

inline

Definition at line 195 of file threads.h.

                              {
        workMutex.lock();
        work.push_back(w);
        workMutex.unlock();
    }

GetNewItem()

template<typename TWorkItem, typename TFunctor>

bool ThreadPool< TWorkItem, TFunctor >::GetNewItem ( TWorkItem &  item )

inlineprotected

Definition at line 231 of file threads.h.

                                     {
        workMutex.lock();
        bool r = !work.empty();
        if (r) {
            item = work.front();
            work.pop_front();
            inProgress++;
        }
        workMutex.unlock();
        return r;
    }

IsDone()

template<typename TWorkItem, typename TFunctor>

bool ThreadPool< TWorkItem, TFunctor >::IsDone ( )

inline

Definition at line 203 of file threads.h.

                  {
        workMutex.lock();
        bool r=work.empty() && inProgress==0;
        workMutex.unlock();
        return r;
    }

ItemDone()

template<typename TWorkItem, typename TFunctor>

void ThreadPool< TWorkItem, TFunctor >::ItemDone ( )

inlineprotected

Definition at line 226 of file threads.h.

                    {
        workMutex.lock();
        inProgress--;
        workMutex.unlock();
    }

ProcessArray()

template<typename TWorkItem, typename TFunctor>

void ThreadPool< TWorkItem, TFunctor >::ProcessArray ( TWorkItem *  items, int  n  )

inline

Definition at line 191 of file threads.h.

                                               {
        for(int i=0;i<n;i++)
            AddWork(items[i]);
    }

Quit()

template<typename TWorkItem, typename TFunctor>

void ThreadPool< TWorkItem, TFunctor >::Quit ( )

inline

Definition at line 209 of file threads.h.

                {
        quit=true;
        for(uint i=0;i<threads.size();i++)
            Threads::WaitAndClose(threads[i]);
        threads.clear();
    }

ThreadEntryPoint()

template<typename TWorkItem, typename TFunctor>

static void ThreadPool< TWorkItem, TFunctor >::ThreadEntryPoint ( void *  param )

inlinestaticprotected

Definition at line 216 of file threads.h.

                                              {
        ThreadPool* pool = ( ThreadPool *)param;
        TWorkItem item;
        while (!pool->quit) {
            if ( pool->GetNewItem(item) ) {
                pool->worker(item);
                pool->ItemDone();
            } else Threads::Sleep(1);
        }
    }

WaitUntilDone()

template<typename TWorkItem, typename TFunctor>

void ThreadPool< TWorkItem, TFunctor >::WaitUntilDone ( )

inline

Definition at line 200 of file threads.h.

                         {
        while(!IsDone()) Threads::Sleep(1);
    }

Member Data Documentation

inProgress

template<typename TWorkItem, typename TFunctor>

int ThreadPool< TWorkItem, TFunctor >::inProgress

protected

Definition at line 245 of file threads.h.

quit

template<typename TWorkItem, typename TFunctor>

Atomic<bool> ThreadPool< TWorkItem, TFunctor >::quit

protected

Definition at line 246 of file threads.h.

threads

template<typename TWorkItem, typename TFunctor>

std::vector<Threads::Handle*> ThreadPool< TWorkItem, TFunctor >::threads

protected

Definition at line 242 of file threads.h.

work

template<typename TWorkItem, typename TFunctor>

std::list<TWorkItem> ThreadPool< TWorkItem, TFunctor >::work

protected

Definition at line 244 of file threads.h.

worker

template<typename TWorkItem, typename TFunctor>

TFunctor ThreadPool< TWorkItem, TFunctor >::worker

protected

Definition at line 247 of file threads.h.

workMutex

template<typename TWorkItem, typename TFunctor>

Threads::Mutex ThreadPool< TWorkItem, TFunctor >::workMutex

protected

Definition at line 243 of file threads.h.

---

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

• cputrack/threads.h