| 1 | /* Threads.h -- multithreading library\r |
| 2 | 2013-11-12 : Igor Pavlov : Public domain */\r |
| 3 | \r |
| 4 | #ifndef __7Z_THREADS_H\r |
| 5 | #define __7Z_THREADS_H\r |
| 6 | \r |
| 7 | #ifdef _WIN32\r |
| 8 | #include <windows.h>\r |
| 9 | #endif\r |
| 10 | \r |
| 11 | #include "7zTypes.h"\r |
| 12 | \r |
| 13 | EXTERN_C_BEGIN\r |
| 14 | \r |
| 15 | WRes HandlePtr_Close(HANDLE *h);\r |
| 16 | WRes Handle_WaitObject(HANDLE h);\r |
| 17 | \r |
| 18 | typedef HANDLE CThread;\r |
| 19 | #define Thread_Construct(p) *(p) = NULL\r |
| 20 | #define Thread_WasCreated(p) (*(p) != NULL)\r |
| 21 | #define Thread_Close(p) HandlePtr_Close(p)\r |
| 22 | #define Thread_Wait(p) Handle_WaitObject(*(p))\r |
| 23 | \r |
| 24 | typedef\r |
| 25 | #ifdef UNDER_CE\r |
| 26 | DWORD\r |
| 27 | #else\r |
| 28 | unsigned\r |
| 29 | #endif\r |
| 30 | THREAD_FUNC_RET_TYPE;\r |
| 31 | \r |
| 32 | #define THREAD_FUNC_CALL_TYPE MY_STD_CALL\r |
| 33 | #define THREAD_FUNC_DECL THREAD_FUNC_RET_TYPE THREAD_FUNC_CALL_TYPE\r |
| 34 | typedef THREAD_FUNC_RET_TYPE (THREAD_FUNC_CALL_TYPE * THREAD_FUNC_TYPE)(void *);\r |
| 35 | WRes Thread_Create(CThread *p, THREAD_FUNC_TYPE func, LPVOID param);\r |
| 36 | \r |
| 37 | typedef HANDLE CEvent;\r |
| 38 | typedef CEvent CAutoResetEvent;\r |
| 39 | typedef CEvent CManualResetEvent;\r |
| 40 | #define Event_Construct(p) *(p) = NULL\r |
| 41 | #define Event_IsCreated(p) (*(p) != NULL)\r |
| 42 | #define Event_Close(p) HandlePtr_Close(p)\r |
| 43 | #define Event_Wait(p) Handle_WaitObject(*(p))\r |
| 44 | WRes Event_Set(CEvent *p);\r |
| 45 | WRes Event_Reset(CEvent *p);\r |
| 46 | WRes ManualResetEvent_Create(CManualResetEvent *p, int signaled);\r |
| 47 | WRes ManualResetEvent_CreateNotSignaled(CManualResetEvent *p);\r |
| 48 | WRes AutoResetEvent_Create(CAutoResetEvent *p, int signaled);\r |
| 49 | WRes AutoResetEvent_CreateNotSignaled(CAutoResetEvent *p);\r |
| 50 | \r |
| 51 | typedef HANDLE CSemaphore;\r |
| 52 | #define Semaphore_Construct(p) (*p) = NULL\r |
| 53 | #define Semaphore_Close(p) HandlePtr_Close(p)\r |
| 54 | #define Semaphore_Wait(p) Handle_WaitObject(*(p))\r |
| 55 | WRes Semaphore_Create(CSemaphore *p, UInt32 initCount, UInt32 maxCount);\r |
| 56 | WRes Semaphore_ReleaseN(CSemaphore *p, UInt32 num);\r |
| 57 | WRes Semaphore_Release1(CSemaphore *p);\r |
| 58 | \r |
| 59 | typedef CRITICAL_SECTION CCriticalSection;\r |
| 60 | WRes CriticalSection_Init(CCriticalSection *p);\r |
| 61 | #define CriticalSection_Delete(p) DeleteCriticalSection(p)\r |
| 62 | #define CriticalSection_Enter(p) EnterCriticalSection(p)\r |
| 63 | #define CriticalSection_Leave(p) LeaveCriticalSection(p)\r |
| 64 | \r |
| 65 | EXTERN_C_END\r |
| 66 | \r |
| 67 | #endif\r |