]>
Commit | Line | Data |
---|---|---|
30fdf114 LG |
1 | /* Threads.c -- multithreading library\r |
2 | 2008-08-05\r | |
3 | Igor Pavlov\r | |
4 | Public domain */\r | |
5 | \r | |
6 | #include "Threads.h"\r | |
7 | #include <process.h>\r | |
8 | \r | |
9 | static WRes GetError()\r | |
10 | {\r | |
11 | DWORD res = GetLastError();\r | |
12 | return (res) ? (WRes)(res) : 1;\r | |
13 | }\r | |
14 | \r | |
15 | WRes HandleToWRes(HANDLE h) { return (h != 0) ? 0 : GetError(); }\r | |
16 | WRes BOOLToWRes(BOOL v) { return v ? 0 : GetError(); }\r | |
17 | \r | |
18 | static WRes MyCloseHandle(HANDLE *h)\r | |
19 | {\r | |
20 | if (*h != NULL)\r | |
21 | if (!CloseHandle(*h))\r | |
22 | return GetError();\r | |
23 | *h = NULL;\r | |
24 | return 0;\r | |
25 | }\r | |
26 | \r | |
27 | WRes Thread_Create(CThread *thread, THREAD_FUNC_RET_TYPE (THREAD_FUNC_CALL_TYPE *startAddress)(void *), LPVOID parameter)\r | |
28 | {\r | |
29 | unsigned threadId; /* Windows Me/98/95: threadId parameter may not be NULL in _beginthreadex/CreateThread functions */\r | |
30 | thread->handle =\r | |
31 | /* CreateThread(0, 0, startAddress, parameter, 0, &threadId); */\r | |
32 | (HANDLE)_beginthreadex(NULL, 0, startAddress, parameter, 0, &threadId);\r | |
33 | /* maybe we must use errno here, but probably GetLastError() is also OK. */\r | |
34 | return HandleToWRes(thread->handle);\r | |
35 | }\r | |
36 | \r | |
37 | WRes WaitObject(HANDLE h)\r | |
38 | {\r | |
39 | return (WRes)WaitForSingleObject(h, INFINITE);\r | |
40 | }\r | |
41 | \r | |
42 | WRes Thread_Wait(CThread *thread)\r | |
43 | {\r | |
44 | if (thread->handle == NULL)\r | |
45 | return 1;\r | |
46 | return WaitObject(thread->handle);\r | |
47 | }\r | |
48 | \r | |
49 | WRes Thread_Close(CThread *thread)\r | |
50 | {\r | |
51 | return MyCloseHandle(&thread->handle);\r | |
52 | }\r | |
53 | \r | |
54 | WRes Event_Create(CEvent *p, BOOL manualReset, int initialSignaled)\r | |
55 | {\r | |
56 | p->handle = CreateEvent(NULL, manualReset, (initialSignaled ? TRUE : FALSE), NULL);\r | |
57 | return HandleToWRes(p->handle);\r | |
58 | }\r | |
59 | \r | |
60 | WRes ManualResetEvent_Create(CManualResetEvent *p, int initialSignaled)\r | |
61 | { return Event_Create(p, TRUE, initialSignaled); }\r | |
62 | WRes ManualResetEvent_CreateNotSignaled(CManualResetEvent *p)\r | |
63 | { return ManualResetEvent_Create(p, 0); }\r | |
64 | \r | |
65 | WRes AutoResetEvent_Create(CAutoResetEvent *p, int initialSignaled)\r | |
66 | { return Event_Create(p, FALSE, initialSignaled); }\r | |
67 | WRes AutoResetEvent_CreateNotSignaled(CAutoResetEvent *p)\r | |
68 | { return AutoResetEvent_Create(p, 0); }\r | |
69 | \r | |
70 | WRes Event_Set(CEvent *p) { return BOOLToWRes(SetEvent(p->handle)); }\r | |
71 | WRes Event_Reset(CEvent *p) { return BOOLToWRes(ResetEvent(p->handle)); }\r | |
72 | WRes Event_Wait(CEvent *p) { return WaitObject(p->handle); }\r | |
73 | WRes Event_Close(CEvent *p) { return MyCloseHandle(&p->handle); }\r | |
74 | \r | |
75 | \r | |
76 | WRes Semaphore_Create(CSemaphore *p, UInt32 initiallyCount, UInt32 maxCount)\r | |
77 | {\r | |
78 | p->handle = CreateSemaphore(NULL, (LONG)initiallyCount, (LONG)maxCount, NULL);\r | |
79 | return HandleToWRes(p->handle);\r | |
80 | }\r | |
81 | \r | |
82 | WRes Semaphore_Release(CSemaphore *p, LONG releaseCount, LONG *previousCount)\r | |
83 | {\r | |
84 | return BOOLToWRes(ReleaseSemaphore(p->handle, releaseCount, previousCount));\r | |
85 | }\r | |
86 | WRes Semaphore_ReleaseN(CSemaphore *p, UInt32 releaseCount)\r | |
87 | {\r | |
88 | return Semaphore_Release(p, (LONG)releaseCount, NULL);\r | |
89 | }\r | |
90 | WRes Semaphore_Release1(CSemaphore *p)\r | |
91 | {\r | |
92 | return Semaphore_ReleaseN(p, 1);\r | |
93 | }\r | |
94 | \r | |
95 | WRes Semaphore_Wait(CSemaphore *p) { return WaitObject(p->handle); }\r | |
96 | WRes Semaphore_Close(CSemaphore *p) { return MyCloseHandle(&p->handle); }\r | |
97 | \r | |
98 | WRes CriticalSection_Init(CCriticalSection *p)\r | |
99 | {\r | |
100 | /* InitializeCriticalSection can raise only STATUS_NO_MEMORY exception */\r | |
101 | __try\r | |
102 | {\r | |
103 | InitializeCriticalSection(p);\r | |
104 | /* InitializeCriticalSectionAndSpinCount(p, 0); */\r | |
105 | }\r | |
106 | __except (EXCEPTION_EXECUTE_HANDLER) { return 1; }\r | |
107 | return 0;\r | |
108 | }\r | |
109 | \r |