MercuryThreads.h

Go to the documentation of this file.

#ifndef _MERCURY_THREADS_H
#define _MERCURY_THREADS_H

#include "MercuryString.h"

#if !defined(WIN32)
#if !defined(_EE)
#include <pthread.h>
#else
#include <kernel.h>
#endif
#endif

class MercuryThread
{
public:
    MercuryThread();
    MercuryThread( const MString &name );
    ~MercuryThread();

    int Create( void * (*fn)(void *), void *data );

    int Wait( long lMilliseconds = 10000000 );

    int Halt( bool kill = true );

    int Resume( );

    void Close( );
private:
    MString m_name;

#if defined(WIN32)
    void * m_thread;
#else  
#if defined(_EE)
    s32 m_thread;
#else
    pthread_t m_thread;
#endif
#endif

};

class MercuryMutex
{
public:
    MercuryMutex( );
    MercuryMutex( const MString &name );
    ~MercuryMutex();
    
    int Wait( long lMilliseconds = 0xFFFFFF );

    int UnLock( );
    
    int Open( );
    
    int Close( );
private:
    MString m_name;

#if defined( WIN32 )
    void * m_mutex;
#else
#if defined( _EE )
    s32 m_mutex;
#else
    pthread_mutex_t m_mutex;
#endif
#endif
};

//http://www.ddj.com/dept/cpp/184403766
//has some very good ideas in terms of threads and volatile variables

template <typename T>
class MLockPtr
{
public:
    MLockPtr(volatile const T& obj, const MercuryMutex& mutex)
        :m_obj(const_cast<T*>(&obj)), m_mutex(const_cast<MercuryMutex*>(&mutex))
    {
        m_mutex->Wait();
    }
    ~MLockPtr() { m_mutex->UnLock(); }
    inline T& operator*() { return *m_obj; }
    inline T* operator->() { return m_obj; }
private:
    T* m_obj;
    MercuryMutex* m_mutex;
    //Disallow
    MLockPtr(const MLockPtr&);
    MLockPtr& operator=(const MLockPtr&);
};

//Utility functions for conditional threading
// The purpose of this is to allow you to conditionally define whether or not a mutex
// exists, allowing one to benchmark the overhead of threading as well as removing 
// functionality if it is known that the system will not be using threads.

#if !defined( NOT_THREADSAFE )

#define COND_MUTEX( x ) \
    MercuryMutex x

#define SETUP_MUTEX( x ) \
    x.Open(); \
    x.UnLock()

#define LOCK_MUTEX( x ) \
    x.Wait()

#define UNLOCK_MUTEX( x ) \
    x.UnLock()

#else

#define COND_MUTEX( x )
#define SETUP_MUTEX( x )
#define LOCK_MUTEX( x )
#define UNLOCK_MUTEX( x )

#endif

#endif

---

Hosted by