WorkQueue Struct Reference

#include "tpool.h"

Inheritance diagram for WorkQueue:

Collaboration diagram for WorkQueue:

Public Types
typedef std::tr1::weak_ptr< epicsThreadRunable >	value_type

Public Member Functions
	WorkQueue (const std::string &name)
virtual	~WorkQueue ()
void	start (unsigned nworkers=1, unsigned prio=epicsThreadPriorityLow)
void	close ()
void	add (const value_type &work)

Detailed Description

Definition at line 18 of file tpool.h.

Member Typedef Documentation

typedef std::tr1::weak_ptr<epicsThreadRunable> WorkQueue::value_type

Definition at line 20 of file tpool.h.

Constructor & Destructor Documentation

WorkQueue::WorkQueue

(

const std::string &

name

)

Definition at line 18 of file tpool.cpp.

    :name(name)
    ,state(Idle)
{}

WorkQueue::~WorkQueue ( )

virtual

Definition at line 23 of file tpool.cpp.

{ close(); }

Member Function Documentation

void WorkQueue::add

(

const value_type &

work

)

Definition at line 79 of file tpool.cpp.

{
    bool empty;

    {
        Guard G(mutex);
        if(state!=Active)
            return;

        empty = queue.empty();

        queue.push_back(work);
    }

    if(empty) {
        wakeup.signal();
    }
}

void WorkQueue::close

(

)

Definition at line 52 of file tpool.cpp.

{
    workers_t temp;

    {
        Guard G(mutex);
        if(state!=Active)
            return;

        temp.swap(workers);
        state = Stopping;
    }

    wakeup.signal();

    for(workers_t::iterator it(temp.begin()), end(temp.end()); it!=end; ++it)
    {
        (*it)->exitWait();
        delete *it;
    }

    {
        Guard G(mutex);
        state = Idle;
    }
}

void WorkQueue::start	(	unsigned	nworkers = 1,
		unsigned	prio = epicsThreadPriorityLow
	)

Definition at line 25 of file tpool.cpp.

{
    Guard G(mutex);

    if(state!=Idle)
        throw std::logic_error("Already started");

    try {
        state = Active;

        for(unsigned i=0; i<nworkers; i++) {
            p2p::auto_ptr<epicsThread> worker(new epicsThread(*this, name.c_str(),
                                                              epicsThreadGetStackSize(epicsThreadStackSmall),
                                                              prio));

            worker->start();

            workers.push_back(worker.get());
            worker.release();
        }
    }catch(...){
        UnGuard U(G); // unlock as close() blocks to join any workers which were started
        close();
        throw;
    }
}

---

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

• modules/pva2pva/pdbApp/tpool.h
• modules/pva2pva/pdbApp/tpool.cpp