--- parser3/src/include/pa_threads.h 2001/01/29 12:16:07 1.4 +++ parser3/src/include/pa_threads.h 2020/12/11 14:59:19 1.35 @@ -1,51 +1,65 @@ -/* - $Id: pa_threads.h,v 1.4 2001/01/29 12:16:07 paf Exp $ +/** @file + Parser: mutex & helpers decls. + + Copyright (c) 2001-2017 Art. Lebedev Studio (http://www.artlebedev.com) + Author: Alexandr Petrosian (http://paf.design.ru) */ #ifndef PA_THREADS_H #define PA_THREADS_H -#ifdef HAVE_CONFIG_H -# include "pa_config.h" -#endif +#define IDENT_PA_THREADS_H "$Id: pa_threads.h,v 1.35 2020/12/11 14:59:19 moko Exp $" +#include "pa_config_includes.h" #include "pa_types.h" +/// get caller thread ID +uint pa_get_thread_id(); -#ifdef MULTITHREAD +class AutoSYNCHRONIZED; +/// simple semaphore object class Mutex { - uint handle; + friend class AutoSYNCHRONIZED; + +#ifdef WIN32 +HANDLE handle; +#else +pthread_mutex_t handle; +#endif + public: Mutex(); ~Mutex(); +private: // for AutoSYNCHRONIZED void acquire(); void release(); }; extern Mutex global_mutex; +/** + Helper to ensure paired Mutex::acquire() and Mutex::release(). + Use it with SYNCHRONIZED macro +*/ + class AutoSYNCHRONIZED { - bool thread_safe; public: - AutoSYNCHRONIZED(bool athread_safe) : thread_safe(athread_safe) { - if(thread_safe) - global_mutex.acquire(); - } - ~AutoSYNCHRONIZED() { - if(thread_safe) - global_mutex.release(); - } -} - -#define SYNCHRONIZED(athread_safe) AutoSYNCHRONIZED autoSYNCHRONIZED(athread_safe) - - -#else // not MULTITHREAD-ed - -#define SYNCHRONIZED(athread_safe) /* do nothing */ + AutoSYNCHRONIZED() { global_mutex.acquire(); } + ~AutoSYNCHRONIZED() { global_mutex.release(); } +}; -#endif +/** + put it to first line of a function to ensure thread safety. + @verbatim + void someclass::somefunc(...) { SYNCHRONIZED; + ... + } + @endverbatim + WARNING: don't use THROW or PTHROW with such thread safety mechanizm - + longjmp would leave global_mutex acquired, which is wrong! +*/ +#define SYNCHRONIZED AutoSYNCHRONIZED autoSYNCHRONIZED #endif