00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024 #ifdef WINDOWS
00025
00026
00027 #include "stdafx.h"
00028 #else
00029
00030 #endif
00031
00032
00033
00034 #ifdef WINDOWS
00035 #include <windows.h>
00036 #else
00037 #include <semaphore.h>
00038 #include <iostream>
00039 #include "RioUnix.h"
00040 #endif
00041
00042 #include "RioSemaphore.h"
00043
00044
00045
00046
00047
00048
00049 CSemaphore::CSemaphore(int InitialValue, int MaxValue)
00050 {
00051 #ifdef WINDOWS
00052
00053 m_handle = CreateSemaphore(NULL,InitialValue,MaxValue,NULL);
00054 if(m_handle == INVALID_HANDLE_VALUE)
00055 {
00056 m_isopen = false;
00057 }
00058 else
00059 {
00060 m_isopen = true;
00061 }
00062 #else
00063
00064 int result = sem_init(&m_Semaphore,0,InitialValue);
00065 if(result == 0)
00066 {
00067 m_isopen = true;
00068 }
00069 else
00070 {
00071 m_isopen = false;
00072 }
00073 #endif
00074
00075 }
00076
00077 CSemaphore::~CSemaphore()
00078 {
00079 if(m_isopen)
00080 {
00081 #ifdef WINDOWS
00082
00083 CloseHandle (m_handle);
00084 m_isopen = false;
00085 #else
00086
00087 sem_destroy(&m_Semaphore);
00088 m_isopen = false;
00089 #endif
00090 }
00091 }
00092
00093 bool CSemaphore::IsOpen()
00094 {
00095 return m_isopen;
00096 }
00097
00098
00099 void CSemaphore::P()
00100 {
00101
00102 #ifdef WINDOWS
00103
00104 WaitForSingleObject(m_handle,INFINITE);
00105 #else
00106
00107 sem_wait(&m_Semaphore);
00108 #endif
00109 }
00110
00111 void CSemaphore::V()
00112 {
00113 #ifdef WINDOWS
00114
00115 ReleaseSemaphore(m_handle,1,NULL);
00116 #else
00117
00118 sem_post(&m_Semaphore);
00119 #endif
00120 }