tpool.h

#ifndef TPOOL_H
#define TPOOL_H

#include <stdexcept>
#include <deque>
#include <vector>
#include <string>

#include <errlog.h>
#include <epicsThread.h>
#include <epicsMutex.h>
#include <epicsEvent.h>

#include <pv/sharedPtr.h>

struct WorkQueue : private epicsThreadRunable
{
    typedef std::tr1::weak_ptr<epicsThreadRunable> value_type;

private:
    const std::string name;

    epicsMutex mutex;

    enum state_t {
        Idle,
        Active,
        Stopping,
    } state;

    typedef std::deque<value_type> queue_t;
    queue_t queue;

    epicsEvent wakeup;

    typedef std::vector<epicsThread*> workers_t;
    workers_t workers;

public:
    WorkQueue(const std::string& name);
    virtual ~WorkQueue();

    void start(unsigned nworkers=1, unsigned prio = epicsThreadPriorityLow);
    void close();

    void add(const value_type& work);

private:
    virtual void run();
};

#endif // TPOOL_H