/home/gian/Progetti/falcon/core/include/falcon/mt_win.h

Go to the documentation of this file.

/*
   FALCON - The Falcon Programming Language.
   FILE: mt_win.h

   Multithreaded extensions - MS-Windows specific header.
   -------------------------------------------------------------------
   Author: Giancarlo Niccolai
   Begin: Sat, 13 Dec 2008 13:08:38 +0100

   -------------------------------------------------------------------
   (C) Copyright 2008: the FALCON developers (see list in AUTHORS file)

   See LICENSE file for licensing details.
*/


#ifndef FALCON_MT_WIN_H
#define FALCON_MT_WIN_H

#include <falcon/setup.h>
#include <falcon/types.h>
#include <falcon/fassert.h>
#include <windows.h>

namespace Falcon
{

class FALCON_DYN_CLASS Mutex
{
   CRITICAL_SECTION m_mtx;

public:
   inline Mutex()
   {
      InitializeCriticalSectionAndSpinCount( &m_mtx, 512 );
   }

   inline ~Mutex() {
      DeleteCriticalSection( &m_mtx );
   }

   inline void lock()
   {
      EnterCriticalSection( &m_mtx );
   }

   inline void unlock()
   {
      LeaveCriticalSection( &m_mtx );
   }

   inline bool trylock()
   {
      return TryEnterCriticalSection( &m_mtx ) == TRUE;
   }

};

class FALCON_DYN_CLASS ThreadSpecific
{
private:
   DWORD m_key;
   void (*m_destructor)(void*);
   ThreadSpecific* m_nextDestructor;

public:
   ThreadSpecific()
   {
      m_key = TlsAlloc();
      m_destructor = 0;
   }

   ThreadSpecific( void (*destructor)(void*) );
   
   virtual ~ThreadSpecific()
   {
      #ifndef NDEBUG
      BOOL res = TlsFree( m_key );
      fassert( res );
      #else
      TlsFree( m_key );
      #endif
   }

   ThreadSpecific* clearAndNext();

   void set( void *value );

   void* get() const
   {
      return TlsGetValue( m_key );
   }
};

inline int32 atomicInc( volatile int32 &data )
{
   volatile LONG* dp = (volatile LONG*) &data;
   return InterlockedIncrement( dp );
}

inline int32 atomicDec( volatile int32 &data )
{
   volatile LONG* dp = (volatile LONG*) &data;
   return InterlockedDecrement( dp );
}

class FALCON_DYN_CLASS Event
{
   HANDLE m_hEvent;

public:
   inline Event( bool bAutoReset = true, bool initState = false )
   {
      // Second parameter is MANUAL RESET
      m_hEvent = CreateEvent( NULL, bAutoReset ? FALSE : TRUE, initState ? TRUE : FALSE, NULL );
   }

   inline ~Event() {
      CloseHandle( m_hEvent );
   }

   inline void set() { SetEvent( m_hEvent ); }


   inline void reset() { ResetEvent( m_hEvent ); }

   bool wait( int32 to = -1 ) { return WaitForSingleObject( m_hEvent, to >= 0 ? to : INFINITE ) == WAIT_OBJECT_0; }
};


struct SYSTH_DATA {
   HANDLE hThread;
   unsigned nThreadID;
   HANDLE hEvtDetach;
   void *retval;
   
   CRITICAL_SECTION m_csT;

   bool m_bDone;
   bool m_bDetached;
   bool m_bJoining;
};


}

#endif

/* end of mt_win.h */

---