diff options
author | Igor Pavlov <ipavlov@users.sourceforge.net> | 2007-05-25 04:00:00 +0400 |
---|---|---|
committer | Kornel LesiĆski <kornel@geekhood.net> | 2016-05-28 02:15:51 +0300 |
commit | c574fc0f4bba94e693b0e22f730d355b75d4f4ce (patch) | |
tree | da4ebd90c776d508ac679d50492f29461db80be0 /C/Threads.c | |
parent | a145bfc7cf17f7bbcfae8f0064333c8ea75b455c (diff) |
4.46 beta
Diffstat (limited to 'C/Threads.c')
-rwxr-xr-x | C/Threads.c | 27 |
1 files changed, 18 insertions, 9 deletions
diff --git a/C/Threads.c b/C/Threads.c index dcf63dcf..def48175 100755 --- a/C/Threads.c +++ b/C/Threads.c @@ -21,12 +21,12 @@ HRes MyCloseHandle(HANDLE *h) return SZ_OK; } -HRes Thread_Create(CThread *thread, unsigned (StdCall *startAddress)(void *), LPVOID parameter) +HRes Thread_Create(CThread *thread, THREAD_FUNC_RET_TYPE (THREAD_FUNC_CALL_TYPE *startAddress)(void *), LPVOID parameter) { - /* DWORD threadId; */ + unsigned threadId; /* Windows Me/98/95: threadId parameter may not be NULL in _beginthreadex/CreateThread functions */ thread->handle = /* CreateThread(0, 0, startAddress, parameter, 0, &threadId); */ - (HANDLE)_beginthreadex(NULL, 0, startAddress, parameter, 0, NULL); + (HANDLE)_beginthreadex(NULL, 0, startAddress, parameter, 0, &threadId); /* maybe we must use errno here, but probably GetLastError() is also OK. */ return BoolToHRes(thread->handle != 0); } @@ -48,13 +48,22 @@ HRes Thread_Close(CThread *thread) return MyCloseHandle(&thread->handle); } -HRes AutoResetEvent_Create(CAutoResetEvent *p, int initialSignaled) +HRes Event_Create(CEvent *p, BOOL manualReset, int initialSignaled) { - p->handle = CreateEvent(NULL, FALSE, (initialSignaled ? TRUE : FALSE), NULL); + p->handle = CreateEvent(NULL, manualReset, (initialSignaled ? TRUE : FALSE), NULL); return BoolToHRes(p->handle != 0); } -HRes AutoResetEvent_CreateNotSignaled(CAutoResetEvent *p) { return AutoResetEvent_Create(p, 0); } +HRes ManualResetEvent_Create(CManualResetEvent *p, int initialSignaled) + { return Event_Create(p, TRUE, initialSignaled); } +HRes ManualResetEvent_CreateNotSignaled(CManualResetEvent *p) + { return ManualResetEvent_Create(p, 0); } + +HRes AutoResetEvent_Create(CAutoResetEvent *p, int initialSignaled) + { return Event_Create(p, FALSE, initialSignaled); } +HRes AutoResetEvent_CreateNotSignaled(CAutoResetEvent *p) + { return AutoResetEvent_Create(p, 0); } + HRes Event_Set(CEvent *p) { return BOOLToHRes(SetEvent(p->handle)); } HRes Event_Reset(CEvent *p) { return BOOLToHRes(ResetEvent(p->handle)); } HRes Event_Wait(CEvent *p) { return WaitObject(p->handle); } @@ -71,9 +80,9 @@ HRes Semaphore_Release(CSemaphore *p, LONG releaseCount, LONG *previousCount) { return BOOLToHRes(ReleaseSemaphore(p->handle, releaseCount, previousCount)); } -HRes Semaphore_ReleaseN(CSemaphore *p, LONG releaseCount) +HRes Semaphore_ReleaseN(CSemaphore *p, UInt32 releaseCount) { - return Semaphore_Release(p, releaseCount, NULL); + return Semaphore_Release(p, (LONG)releaseCount, NULL); } HRes Semaphore_Release1(CSemaphore *p) { @@ -89,7 +98,7 @@ HRes CriticalSection_Init(CCriticalSection *p) __try { InitializeCriticalSection(p); - // InitializeCriticalSectionAndSpinCount(p, 0); + /* InitializeCriticalSectionAndSpinCount(p, 0); */ } __except (EXCEPTION_EXECUTE_HANDLER) { return SZE_OUTOFMEMORY; } return SZ_OK; |