solaristhreads.h
上传用户:dangjiwu
上传日期:2013-07-19
资源大小:42019k
文件大小:6k
源码类别:

Symbian

开发平台:

Visual C++

  1. /* ***** BEGIN LICENSE BLOCK *****
  2.  * Source last modified: $Id: solaristhreads.h,v 1.2.2.3 2004/07/09 01:43:45 hubbe Exp $
  3.  * 
  4.  * Portions Copyright (c) 1995-2004 RealNetworks, Inc. All Rights Reserved.
  5.  * 
  6.  * The contents of this file, and the files included with this file,
  7.  * are subject to the current version of the RealNetworks Public
  8.  * Source License (the "RPSL") available at
  9.  * http://www.helixcommunity.org/content/rpsl unless you have licensed
  10.  * the file under the current version of the RealNetworks Community
  11.  * Source License (the "RCSL") available at
  12.  * http://www.helixcommunity.org/content/rcsl, in which case the RCSL
  13.  * will apply. You may also obtain the license terms directly from
  14.  * RealNetworks.  You may not use this file except in compliance with
  15.  * the RPSL or, if you have a valid RCSL with RealNetworks applicable
  16.  * to this file, the RCSL.  Please see the applicable RPSL or RCSL for
  17.  * the rights, obligations and limitations governing use of the
  18.  * contents of the file.
  19.  * 
  20.  * Alternatively, the contents of this file may be used under the
  21.  * terms of the GNU General Public License Version 2 or later (the
  22.  * "GPL") in which case the provisions of the GPL are applicable
  23.  * instead of those above. If you wish to allow use of your version of
  24.  * this file only under the terms of the GPL, and not to allow others
  25.  * to use your version of this file under the terms of either the RPSL
  26.  * or RCSL, indicate your decision by deleting the provisions above
  27.  * and replace them with the notice and other provisions required by
  28.  * the GPL. If you do not delete the provisions above, a recipient may
  29.  * use your version of this file under the terms of any one of the
  30.  * RPSL, the RCSL or the GPL.
  31.  * 
  32.  * This file is part of the Helix DNA Technology. RealNetworks is the
  33.  * developer of the Original Code and owns the copyrights in the
  34.  * portions it created.
  35.  * 
  36.  * This file, and the files included with this file, is distributed
  37.  * and made available on an 'AS IS' basis, WITHOUT WARRANTY OF ANY
  38.  * KIND, EITHER EXPRESS OR IMPLIED, AND REALNETWORKS HEREBY DISCLAIMS
  39.  * ALL SUCH WARRANTIES, INCLUDING WITHOUT LIMITATION, ANY WARRANTIES
  40.  * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, QUIET
  41.  * ENJOYMENT OR NON-INFRINGEMENT.
  42.  * 
  43.  * Technology Compatibility Kit Test Suite(s) Location:
  44.  *    http://www.helixcommunity.org/content/tck
  45.  * 
  46.  * Contributor(s):
  47.  * 
  48.  * ***** END LICENSE BLOCK ***** */
  49. #ifndef _SOLARISTHREADSH
  50. #define _SOLARISTHREADSH
  51. #include "UnixThreads.h"
  52. // forward declare
  53. class HXSolarisCondition;
  54. //=======================================================================
  55. //
  56. //                      HXSolarisMutex
  57. //                   ------------------
  58. //
  59. // NOTE: Mutexs must be recursive.
  60. //=======================================================================
  61. class HXSolarisMutex : public HXUnixMutex
  62. {
  63.   public:
  64.     //Ctors and dtors.
  65.     HXSolarisMutex();
  66.     virtual ~HXSolarisMutex();
  67.     friend class HXSolarisCondition;
  68. protected:
  69.     //Must be recursive
  70.     virtual HX_RESULT _Lock();
  71.     virtual HX_RESULT _Unlock();
  72.     virtual HX_RESULT _TryLock();
  73.     
  74.     mutex_t* _GetSolarisMutex() { return &m_mutex; }
  75. private:
  76.     mutex_t m_mutex;
  77.     //These are used to simulate recursive mutexes on systems that don't
  78.     //have them.
  79.     ULONG32  m_ulOwnerThread;
  80.     ULONG32  m_ulLockCount;
  81.     mutex_t  m_mtxLockLock; //A mutex to protect the mutex!
  82.     //Prevent unintentional ctors
  83.     HXSolarisMutex( const HXSolarisMutex& ); //copy ctor
  84.     HXSolarisMutex& operator=(const HXSolarisMutex& ); //assignment operator.
  85. };
  86. //=======================================================================
  87. //
  88. //                      HXSolarisSemaphore
  89. //                   ------------------
  90. //
  91. //=======================================================================
  92. class HXSolarisSemaphore : public HXUnixSemaphore
  93. {
  94.   public:
  95.     //Ctors and dtors.
  96.     HXSolarisSemaphore(UINT32 unInitialCount=0);
  97.     virtual ~HXSolarisSemaphore();
  98.         
  99. protected:
  100.     virtual HX_RESULT _Post();
  101.     virtual HX_RESULT _Wait();
  102.     virtual HX_RESULT _TryWait();
  103.     virtual HX_RESULT _GetValue(int* pnCount );
  104. private:
  105.     sema_t m_semaphore;
  106.     
  107.     //Prevent unintentional ctors
  108.     HXSolarisSemaphore( const HXSolarisSemaphore& ); //copy ctor
  109.     HXSolarisSemaphore& operator=(const HXSolarisSemaphore& ); //assignment operator.
  110. };
  111. //=======================================================================
  112. //
  113. //                    HXSolarisThread    
  114. //                   ------------------
  115. //
  116. //=======================================================================
  117. class HXSolarisThread : public HXUnixThread
  118. {
  119.   public:
  120.     HXSolarisThread();
  121.     virtual ~HXSolarisThread();
  122. protected:
  123.     //
  124.     // Pure virtuals that implement the OS specific chores.
  125.     //
  126.     virtual HX_RESULT _thread_create( ULONG32& ulThreadID, void*(pfExecFunc(void*)), void* pArg );
  127.     virtual ULONG32   _thread_self();
  128.     virtual void      _thread_exit(UINT32 unExitCode);
  129.     virtual void      _thread_cancel(ULONG32 ulThreadID);
  130.     virtual ULONG32   _thread_join(ULONG32 ulThreadID);
  131.     
  132. private:
  133.     //Prevent unintentional ctors
  134.     HXSolarisThread( const HXSolarisThread& ); //copy ctor
  135.     HXSolarisThread& operator=(const HXSolarisThread&); //assignment operator.
  136. };
  137. class HXSolarisCondition : public HXUnixCondition
  138. {
  139. public:
  140.     HXSolarisCondition(HXUnixMutex*& pMutex);
  141.     virtual ~HXSolarisCondition();
  142. protected:
  143.     virtual HX_RESULT _Wait();
  144.     virtual HX_RESULT _TimedWait( UINT32 uTimeoutPeriod = ALLFS);
  145.     virtual HX_RESULT _Broadcast();
  146.     virtual HX_RESULT _Signal();
  147. private:
  148.     HXSolarisMutex* m_pMutex;
  149.     cond_t   m_cond;
  150.     //Protect unintentional ctors
  151.     HXSolarisCondition( const HXSolarisCondition& ); //copy ctor.
  152.     HXSolarisCondition& operator=(const HXSolarisCondition& ); //assignment oper.
  153. };
  154. #endif //_SOLARISTHREADSH