MeVis/Foundation/Sources/DicomTree/MLDicomTree/DCMTree_ThreadSupport.h

Go to the documentation of this file.

//-----------------------------------------------------------------------------
// **InsertLicense** code
//-----------------------------------------------------------------------------

//-----------------------------------------------------------------------------

#ifndef CLASS_DCMTREE_THREADSUPPORT
#define CLASS_DCMTREE_THREADSUPPORT

#ifdef WIN32
    #ifndef NOMINMAX
        #define NOMINMAX
    #endif
    #include <process.h>
    #include <winsock2.h>
    #include <windows.h>
    #include <winbase.h>
    #undef small
#else
    #include <pthread.h>
    #include <signal.h>
    
    #ifdef MACOS
        #include <mach/semaphore.h>
    #else
        #ifndef sem_t
            #include <semaphore.h>
        #endif
    #endif
#endif

#include "DCMTree_Defines.h"


namespace DCMTree_Utils
{
    typedef void* thread_parameter;

    #ifdef WIN32
        #define thread_modifier  __stdcall
        typedef unsigned int     thread_result;
        typedef HANDLE           thread_id;
        typedef thread_result    (thread_modifier *thread_function)(thread_parameter);
        typedef CRITICAL_SECTION thread_criticalsection;
        typedef HANDLE           thread_semaphore;
    #else
        #define thread_modifier 
        typedef void*            thread_result;
        typedef pthread_t        thread_id;
        typedef thread_result    (*thread_function)(thread_parameter);
        typedef pthread_mutex_t  thread_criticalsection;
        #ifdef MACOS
            typedef semaphore_t  thread_semaphore;
        #else
            typedef sem_t        thread_semaphore;
        #endif
    #endif




    // system independent multi threading functions


    thread_id DCMTREE_EXPORT thread_start (thread_function func,thread_parameter param);


    void DCMTREE_EXPORT thread_await (thread_id id);


    bool DCMTREE_EXPORT thread_running (thread_id id);


    void DCMTREE_EXPORT thread_initcriticalsection (thread_criticalsection &cs);


    void DCMTREE_EXPORT thread_entercriticalsection (thread_criticalsection &cs);


    void DCMTREE_EXPORT thread_leavecriticalsection (thread_criticalsection &cs);


    void DCMTREE_EXPORT thread_destroycriticalsection (thread_criticalsection &cs);



    void DCMTREE_EXPORT thread_initsemaphore (thread_semaphore &s,int initcount=0);


    void DCMTREE_EXPORT thread_destroysemaphore (thread_semaphore &s);


    void DCMTREE_EXPORT thread_waitsemaphore (thread_semaphore &s);


    bool DCMTREE_EXPORT thread_waitsemaphore (thread_semaphore &s, unsigned long timeout);


    void DCMTREE_EXPORT thread_postsemaphore (thread_semaphore &s);

    class DCMTREE_EXPORT thread_scoped_criticalsection
    {
    public:
        thread_scoped_criticalsection (thread_criticalsection &cs):_cs(cs)
        {
            thread_entercriticalsection (_cs);
        };
        
        ~thread_scoped_criticalsection()
        {
            thread_leavecriticalsection (_cs);
        };

    private:
        thread_criticalsection &_cs;
        
        thread_scoped_criticalsection& operator=(const thread_scoped_criticalsection&);
    };
}

#endif