TRWorkerThread.h

Go to the documentation of this file.

/* This file is part of the Transient Recorder Framework.
 * It is subject to the license terms in the LICENSE.txt file found in the
 * top-level directory of this distribution and at
 * https://confluence.slac.stanford.edu/display/ppareg/LICENSE.html. No part
 * of the Transient Recorder Framework, including this file, may be copied,
 * modified, propagated, or distributed except according to the terms
 * contained in the LICENSE.txt file.
 */

#ifndef TRANSREC_WORKER_THREAD_H
#define TRANSREC_WORKER_THREAD_H

#include <deque>
#include <string>

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

#include "TRNonCopyable.h"

class TRWorkerThreadRunnable
{
public:
    virtual void runWorkerThreadTask (int id) = 0;
};

class TRWorkerThreadTask;

class TRWorkerThread :
    private TRNonCopyable,
    private epicsThreadRunable
{
    friend class TRWorkerThreadTask;
    
public:
    TRWorkerThread (std::string const &thread_name);
    
    ~TRWorkerThread ();
    
    void start ();
    
    void stop ();
    
private:
    bool m_stop;
    epicsThread m_thread;
    epicsMutex m_mutex;
    epicsEvent m_event;
    std::deque<TRWorkerThreadTask *> m_queue;
    
private:
    void run ();
};

class TRWorkerThreadTask :
    private TRNonCopyable
{
    friend class TRWorkerThread;
    
public:
    TRWorkerThreadTask ();
    
    TRWorkerThreadTask (TRWorkerThread *worker, TRWorkerThreadRunnable *runnable, int id);
    
    void init (TRWorkerThread *worker, TRWorkerThreadRunnable *runnable, int id);
    
    ~TRWorkerThreadTask ();
    
    bool start ();
    
    bool cancel ();
    
private:
    TRWorkerThread *m_worker;
    TRWorkerThreadRunnable *m_runnable;
    int m_id;
};

#endif