1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
/*
* Scilab ( http://www.scilab.org/ ) - This file is part of Scilab
* Copyright (C) 2008-2008 - INRIA - Bruno JOFRET
* Copyright (C) 2008-2008 - INRIA - Allan CORNET
*
* This file must be used under the terms of the CeCILL.
* This source file is licensed as described in the file COPYING, which
* you should have received as part of this distribution. The terms
* are also available at
* http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt
*
*/
/*
** Thread wrapper to have an easy way to manage
** those features on each platform
*/
#ifndef __THREAD_WRAPPER_H__
#define __THREAD_WRAPPER_H__
#ifdef _MSC_VER
#ifndef _WIN32_WINNT
#define _WIN32_WINNT 0x500
#endif
#include <Windows.h>
#include <process.h>
typedef HANDLE __threadId;
typedef HANDLE __threadLock;
typedef CRITICAL_SECTION __threadSignalLock;
typedef HANDLE __threadSignal;
#define __InitSignalLock(lockName) InitializeCriticalSection(lockName)
#define __LockSignal(lockName) EnterCriticalSection(lockName)
#define __UnLockSignal(lockName) LeaveCriticalSection(lockName)
#define __InitLock(lockName) (*(lockName)=CreateMutex(NULL, FALSE, NULL))
#define __Lock(lockName) WaitForSingleObject(*lockName, INFINITE)
#define __UnLock(lockName) ReleaseMutex(*lockName)
#define __InitSignal(signalName) (*signalName=CreateEvent(NULL, FALSE, FALSE, NULL))
#define __Signal(signalName) SetEvent(*signalName)
#define __Wait(signalName, lockName) {ResetEvent(*signalName); __UnLockSignal(lockName); WaitForSingleObject(*signalName, INFINITE); __LockSignal(lockName);};
#define __CreateThread(threadId, functionName) *(threadId) = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)functionName, NULL, 0, NULL)
#define __WaitThreadDie(threadId) ((WaitForSingleObject((threadId),INFINITE)!=WAIT_OBJECT_0) || !CloseHandle(threadId))
#define __Terminate(threadId) TerminateThread(threadId, 0)
#define __StaticInitLock NULL
#define __StaticInitThreadSignal NULL
#else
#include <pthread.h>
typedef pthread_t __threadId;
typedef pthread_mutex_t __threadLock;
typedef pthread_mutex_t __threadSignalLock;
typedef pthread_cond_t __threadSignal;
#define __InitLock(lockName) pthread_mutex_init(lockName, NULL)
#define __Lock(lockName) pthread_mutex_lock(lockName)
#define __UnLock(lockName) pthread_mutex_unlock(lockName)
/* PTHREAD_MUTEX_ERRORCHECK needed for a safe release atexit when we try to release without knowing if we own the lock
PTHREAD_PROCESS_SHARED needed for interprocess synch (plus alloc in shared mem thread_mutexattr_settype
Linux uses PTHREAD_MUTEX_ERRORCHECK_NP other Posix use PTHREAD_MUTEX_ERRORCHECK
*/
#ifndef PTHREAD_MUTEX_ERRORCHECK
#define PTHREAD_MUTEX_ERRORCHECK PTHREAD_MUTEX_ERRORCHECK_NP
#endif
#define __InitSignalLock(lockName) \
do { \
pthread_mutexattr_t attr; \
pthread_mutexattr_init (&attr); \
pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_ERRORCHECK); \
pthread_mutexattr_setpshared (&attr, PTHREAD_PROCESS_SHARED); \
pthread_mutex_init(lockName, NULL); \
pthread_mutexattr_destroy(&attr); \
} while (0)
#define __LockSignal(lockName) pthread_mutex_lock(lockName)
#define __UnLockSignal(lockName) pthread_mutex_unlock(lockName)
#define __InitSignal(signalName) pthread_cond_init(signalName, NULL)
#define __Signal(signalName) pthread_cond_signal(signalName)
#define __Wait(signalName, lockName) pthread_cond_wait(signalName, lockName)
#define __CreateThread(threadId, functionName) pthread_create(threadId, NULL, functionName, NULL)
#define __WaitThreadDie(threadId) pthread_join(threadId, NULL)
#define __Terminate(threadId) pthread_cancel(threadId)
#define __StaticInitLock PTHREAD_MUTEX_INITIALIZER
#define __StaticInitThreadSignal PTHREAD_COND_INITIALIZER
#endif //_MSC_VER
#endif /* !__THREAD_WRAPPER_H__ */
|
