as_thread.h 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103
  1. /*
  2. AngelCode Scripting Library
  3. Copyright (c) 2003-2012 Andreas Jonsson
  4. This software is provided 'as-is', without any express or implied
  5. warranty. In no event will the authors be held liable for any
  6. damages arising from the use of this software.
  7. Permission is granted to anyone to use this software for any
  8. purpose, including commercial applications, and to alter it and
  9. redistribute it freely, subject to the following restrictions:
  10. 1. The origin of this software must not be misrepresented; you
  11. must not claim that you wrote the original software. If you use
  12. this software in a product, an acknowledgment in the product
  13. documentation would be appreciated but is not required.
  14. 2. Altered source versions must be plainly marked as such, and
  15. must not be misrepresented as being the original software.
  16. 3. This notice may not be removed or altered from any source
  17. distribution.
  18. The original version of this library can be located at:
  19. http://www.angelcode.com/angelscript/
  20. Andreas Jonsson
  21. [email protected]
  22. */
  23. //
  24. // as_thread.h
  25. //
  26. // Classes for multi threading support
  27. //
  28. #ifndef AS_THREAD_H
  29. #define AS_THREAD_H
  30. #include "as_config.h"
  31. #include "as_string.h"
  32. #include "as_array.h"
  33. #include "as_map.h"
  34. #include "as_criticalsection.h"
  35. BEGIN_AS_NAMESPACE
  36. class asCThreadLocalData;
  37. class asCThreadManager
  38. {
  39. public:
  40. static asCThreadLocalData *GetLocalData();
  41. static int CleanupLocalData();
  42. static void Prepare();
  43. static void Unprepare();
  44. // This read/write lock can be used by the application to provide simple synchronization
  45. DECLAREREADWRITELOCK(appRWLock)
  46. protected:
  47. asCThreadManager();
  48. ~asCThreadManager();
  49. // No need to use the atomic int here, as it will only be
  50. // updated within the thread manager's critical section
  51. int refCount;
  52. #ifndef AS_NO_THREADS
  53. DECLARECRITICALSECTION(criticalSection);
  54. asCThreadLocalData *GetLocalData(asPWORD threadId);
  55. void SetLocalData(asPWORD threadId, asCThreadLocalData *tld);
  56. asCMap<asPWORD,asCThreadLocalData*> tldMap;
  57. #else
  58. asCThreadLocalData *tld;
  59. #endif
  60. };
  61. //======================================================================
  62. class asIScriptContext;
  63. class asCThreadLocalData
  64. {
  65. public:
  66. asCArray<asIScriptContext *> activeContexts;
  67. asCString string;
  68. protected:
  69. friend class asCThreadManager;
  70. asCThreadLocalData();
  71. ~asCThreadLocalData();
  72. };
  73. END_AS_NAMESPACE
  74. #endif