threadengine.h

Go to the documentation of this file.

/*
 *
 * (C) 2003-2013 Anope Team
 * Contact us at team@anope.org
 *
 * Please read COPYING and README for further details.
 *
 * Based on the original code of Epona by Lara.
 * Based on the original code of Services by Andy Church.
 *
 */

#ifndef THREADENGINE_H
#define THREADENGINE_H

#include "sockets.h"
#include "extensible.h"

class CoreExport Thread : public Pipe, public Extensible
{
 private:
        /* Set to true to tell the thread to finish and we are waiting for it */
        bool exit;

 public:
        /* Handle for this thread */
        pthread_t handle;

        Thread();

        virtual ~Thread();

        void Join();

        void SetExitState();

        void Exit();

        void Start();

        bool GetExitState() const;

        void OnNotify();

        virtual void Run() = 0;
};

class CoreExport Mutex
{
 protected:
        /* A mutex, used to keep threads in sync */
        pthread_mutex_t mutex;

 public:
        Mutex();

        ~Mutex();

        void Lock();

        void Unlock();

        bool TryLock();
};

class CoreExport Condition : public Mutex
{
 private:
        /* A condition */
        pthread_cond_t cond;

 public:
        Condition();

        ~Condition();

        void Wakeup();

        void Wait();
};

#endif // THREADENGINE_H