NeoPZ
TPZThreadTools.cpp
Go to the documentation of this file.
1 #include "TPZThreadTools.h"
2 #include "pzerror.h"
3 
5 namespace tht
6 {
7 
9 
10  void InitializeCriticalSection(pz_critical_section_t & cs)
11  {
12 #ifdef using_pthread
13  pthread_mutexattr_t * nullPtr = NULL;
14  pthread_mutex_init(&cs, nullPtr);
15 #endif
16 #ifdef WINDOWS_THREADS
17  ::InitializeCriticalSection(&cs);
18 #endif
19 #ifdef EMBARCADERO_THREADS
20  cs = new TCriticalSection();
21 #endif
22  }
23 
24  void DeleteCriticalSection(pz_critical_section_t & cs)
25  {
26 #ifdef using_pthread
27  pthread_mutex_destroy(&cs);
28 #endif
29 #ifdef WINDOWS_THREADS
30  ::DeleteCriticalSection(&cs);
31 #endif
32 #ifdef EMBARCADERO_THREADS
33  // ::DeleteCriticalSection( &cs );
35 #endif
36  }
37 
38  void EnterCriticalSection(pz_critical_section_t & cs)
39  {
40 #ifdef using_pthread
41  pthread_mutex_lock(&cs);
42 #endif
43 #ifdef WINDOWS_THREADS
44  ::EnterCriticalSection(&cs);
45 #endif
46 #ifdef EMBARCADERO_THREADS
47  // ::EnterCriticalSection(&cs);
48  cs->Enter();
49 #endif
50  }
51 
52  void LeaveCriticalSection(pz_critical_section_t & cs)
53  {
54 #ifdef using_pthread
55  pthread_mutex_unlock(&cs);
56 #endif
57 #ifdef WINDOWS_THREADS
58  ::LeaveCriticalSection(&cs);
59 #endif
60 #ifdef EMBARCADERO_THREADS
61  // ::LeaveCriticalSection(&cs);
62  cs->Leave();
63 #endif
64  }
65 
67 
68  void InitializeMutex(pz_mutex_t & m)
69  {
70 #ifdef using_pthread
71  pthread_mutexattr_t * nullPtr = NULL;
72  pthread_mutex_init(&m, nullPtr);
73 #endif
74 #ifdef WINDOWS_THREADS
75  m = CreateMutex(NULL, false, NULL);
76  if(!m)
77  {
78  MessageBox(NULL, "Error", "Fail to create Windows Mutex",
79  MB_OK | MB_ICONERROR);
80  DebugStop();
81  }
82 #endif
83 #ifdef EMBARCADERO_THREADS
84  m = new TMutex(false);
85 #endif
86  }
87 
88  void DeleteMutex(pz_mutex_t & m)
89  {
90 #ifdef using_pthread
91  pthread_mutex_destroy(&m);
92 #endif
93 #ifdef WINDOWS_THREADS
94  CloseHandle(m);
95 #endif
96 #ifdef EMBARCADERO_THREADS
97 #endif
99  }
100 
101  void MutexLock(pz_mutex_t & m)
102  {
103 #ifdef using_pthread
104  pthread_mutex_lock(&m);
105 #endif
106 #ifdef WINDOWS_THREADS
107  WaitForSingleObject(m, INFINITE);
108 #endif
109 #ifdef EMBARCADERO_THREADS
110  m->Acquire();
111 #endif
112  }
113 
114  void MutexUnlock(pz_mutex_t & m)
115  {
116 #ifdef using_pthread
117  pthread_mutex_unlock(&m);
118 #endif
119 #ifdef WINDOWS_THREADS
120  ::ReleaseMutex(m);
121 #endif
122 #ifdef EMBARCADERO_THREADS
123  m->Release();
124 #endif
125  }
126 
128 
129  int InitializeSemaphore(pz_semaphore_t & s)
130  {
131 #ifdef using_pthread
132 // int sem_result = sem_init(&s, 0, 0);
133 // return sem_result;
134  // In TPZSemaphore nothing needs to be done (remember to create an object TPZSemaphore and not a pointer)
135 #endif
136 #ifdef WINDOWS_THREADS
137  s = ::CreateSemaphore(NULL, 0, 1, NULL);
138  if(!s)
139  {
140  MessageBox(NULL, "Error", "Fail to create Windows Mutex",
141  MB_OK | MB_ICONERROR);
142  DebugStop();
143  return 1;
144  }
145  return 0;
146 #endif
147 #ifdef EMBARCADERO_THREADS
148  int max = INT_MAX;
149  System::UnicodeString name = "";
150  s = new TSemaphore(NULL, 0, max, name, false);
151  return 0;
152 #endif
153  return 0;
154  }
155 
156  void DeleteSemaphore(pz_semaphore_t & s)
157  {
158 #ifdef using_pthread
159 // sem_destroy(&s);
160  // as it is and object (and not a pointer) it will be destroied at the end of the scope
161 
162 #endif
163 #ifdef WINDOWS_THREADS
164  CloseHandle(s);
165 #endif
166 #ifdef EMBARCADERO_THREADS
167 #endif
169  }
170 
171  void SemaphorePost(pz_semaphore_t & s)
172  {
173 #ifdef using_pthread
174 // sem_post(&s);
175  s.Post();
176  //(remember to create an object TPZSemaphore and not a pointer)
177 #endif
178 #ifdef WINDOWS_THREADS
179  int64_t pCount = 0;
180  ::ReleaseSemaphore(s, 1, &pCount);
181 #endif
182 #ifdef EMBARCADERO_THREADS
183  s->Release();
184 #endif
185  }
186 
187  void SemaphoreWait(pz_semaphore_t & s)
188  {
189 #ifdef using_pthread
190  //sem_wait(&s);
191  s.Wait();
192  //(remember to create an object TPZSemaphore and not a pointer)
193 #endif
194 #ifdef WINDOWS_THREADS
195  WaitForSingleObject(s, INFINITE);
196 #endif
197 #ifdef EMBARCADERO_THREADS
198  s->Acquire();
199 #endif
200  }
201 
203 
204  void CreateThread(pz_thread_t & thread, void* (*function)(void* param),
205  void* data)
206  {
207 #ifdef using_pthread
208  pthread_attr_t * attr = NULL;
209  int res = pthread_create(&thread, attr, function, data);
210  if (res)
211  DebugStop();
212 #endif
213 #ifdef WINDOWS_THREADS
214  thread = ::CreateThread(NULL, 0, (uint64_t (__stdcall* )(void *))function, data, 0, NULL);
215 #endif
216 #ifdef EMBARCADERO_THREADS
217  thread = new TSWXEmbarcaderoThread(function, data);
218 #endif
219  }
220 
221  void ThreadWaitFor(pz_thread_t & thread)
222  {
223 #ifdef using_pthread
224  pthread_join(thread, NULL);
225 #endif
226 #ifdef WINDOWS_THREADS
227  WaitForSingleObject(thread, INFINITE);
228 #endif
229 #ifdef EMBARCADERO_THREADS
230  thread->WaitFor();
231 #endif
232  }
233 
234 }
tht::DeleteSemaphore
void DeleteSemaphore(pz_semaphore_t &s)
Definition: TPZThreadTools.cpp:156
TPZSemaphore
Implements semaphore to threads. Utility.
Definition: TPZSemaphore.h:15
tht::InitializeSemaphore
int InitializeSemaphore(pz_semaphore_t &s)
Semaforos.
Definition: TPZThreadTools.cpp:129
pz_critical_section_t
pthread_mutex_t pz_critical_section_t
Definition: TPZThreadTools.h:26
tht::MutexUnlock
void MutexUnlock(pz_mutex_t &m)
Definition: TPZThreadTools.cpp:114
pzerror.h
Defines PZError.
tht::LeaveCriticalSection
void LeaveCriticalSection(pz_critical_section_t &cs)
Definition: TPZThreadTools.cpp:52
TPZThreadTools.h
pz_mutex_t
pthread_mutex_t pz_mutex_t
Definition: TPZThreadTools.h:27
tht::EnterCriticalSection
void EnterCriticalSection(pz_critical_section_t &cs)
Definition: TPZThreadTools.cpp:38
tht::CreateThread
void CreateThread(pz_thread_t &thread, void *(*function)(void *param), void *data)
Threads.
Definition: TPZThreadTools.cpp:204
tht::InitializeCriticalSection
void InitializeCriticalSection(pz_critical_section_t &cs)
Critical sections.
Definition: TPZThreadTools.cpp:10
tht::ThreadWaitFor
void ThreadWaitFor(pz_thread_t &thread)
Definition: TPZThreadTools.cpp:221
DebugStop
#define DebugStop()
Returns a message to user put a breakpoint in.
Definition: pzerror.h:20
test.res
string res
Definition: test.py:151
tht::MutexLock
void MutexLock(pz_mutex_t &m)
Definition: TPZThreadTools.cpp:101
tht::SemaphoreWait
void SemaphoreWait(pz_semaphore_t &s)
Definition: TPZThreadTools.cpp:187
tht::SemaphorePost
void SemaphorePost(pz_semaphore_t &s)
Definition: TPZThreadTools.cpp:171
pz_thread_t
pthread_t pz_thread_t
Definition: TPZThreadTools.h:29
m
clarg::argString m("-m", "input matrix file name (text format)", "matrix.txt")
tht::DeleteMutex
void DeleteMutex(pz_mutex_t &m)
Definition: TPZThreadTools.cpp:88
tht
namespace tht means "ThreadTools"
Definition: TPZThreadTools.cpp:5
tht::InitializeMutex
void InitializeMutex(pz_mutex_t &m)
Mutexes.
Definition: TPZThreadTools.cpp:68
tht::DeleteCriticalSection
void DeleteCriticalSection(pz_critical_section_t &cs)
Definition: TPZThreadTools.cpp:24
Generated on Sun Aug 16 2020 11:17:11 for NeoPZ by   doxygen 1.8.13