thread_safe.h 2.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182
  1. /*************************************************************************/
  2. /* thread_safe.h */
  3. /*************************************************************************/
  4. /* This file is part of: */
  5. /* GODOT ENGINE */
  6. /* http://www.godotengine.org */
  7. /*************************************************************************/
  8. /* Copyright (c) 2007-2015 Juan Linietsky, Ariel Manzur. */
  9. /* */
  10. /* Permission is hereby granted, free of charge, to any person obtaining */
  11. /* a copy of this software and associated documentation files (the */
  12. /* "Software"), to deal in the Software without restriction, including */
  13. /* without limitation the rights to use, copy, modify, merge, publish, */
  14. /* distribute, sublicense, and/or sell copies of the Software, and to */
  15. /* permit persons to whom the Software is furnished to do so, subject to */
  16. /* the following conditions: */
  17. /* */
  18. /* The above copyright notice and this permission notice shall be */
  19. /* included in all copies or substantial portions of the Software. */
  20. /* */
  21. /* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
  22. /* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
  23. /* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
  24. /* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
  25. /* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
  26. /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
  27. /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
  28. /*************************************************************************/
  29. #ifndef THREAD_SAFE_H
  30. #define THREAD_SAFE_H
  31. #include "os/mutex.h"
  32. class ThreadSafe {
  33. Mutex *mutex;
  34. public:
  35. inline void lock() const { if (mutex) mutex->lock(); }
  36. inline void unlock() const { if (mutex) mutex->unlock(); }
  37. ThreadSafe();
  38. ~ThreadSafe();
  39. };
  40. class ThreadSafeMethod {
  41. const ThreadSafe *_ts;
  42. public:
  43. ThreadSafeMethod(const ThreadSafe *p_ts) {
  44. _ts=p_ts;
  45. _ts->lock();
  46. }
  47. ~ThreadSafeMethod() { _ts->unlock(); }
  48. };
  49. #ifndef NO_THREADS
  50. #define _THREAD_SAFE_CLASS_ ThreadSafe __thread__safe__;
  51. #define _THREAD_SAFE_METHOD_ ThreadSafeMethod __thread_safe_method__(&__thread__safe__);
  52. #define _THREAD_SAFE_LOCK_ __thread__safe__.lock();
  53. #define _THREAD_SAFE_UNLOCK_ __thread__safe__.unlock();
  54. #else
  55. #define _THREAD_SAFE_CLASS_
  56. #define _THREAD_SAFE_METHOD_
  57. #define _THREAD_SAFE_LOCK_
  58. #define _THREAD_SAFE_UNLOCK_
  59. #endif
  60. #endif