/*************************************************************************/ /* thread_local.h */ /*************************************************************************/ /* This file is part of: */ /* GODOT ENGINE */ /* https://godotengine.org */ /*************************************************************************/ /* Copyright (c) 2007-2018 Juan Linietsky, Ariel Manzur. */ /* Copyright (c) 2014-2018 Godot Engine contributors (cf. AUTHORS.md) */ /* */ /* Permission is hereby granted, free of charge, to any person obtaining */ /* a copy of this software and associated documentation files (the */ /* "Software"), to deal in the Software without restriction, including */ /* without limitation the rights to use, copy, modify, merge, publish, */ /* distribute, sublicense, and/or sell copies of the Software, and to */ /* permit persons to whom the Software is furnished to do so, subject to */ /* the following conditions: */ /* */ /* The above copyright notice and this permission notice shall be */ /* included in all copies or substantial portions of the Software. */ /* */ /* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */ /* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */ /* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/ /* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */ /* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */ /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */ /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ /*************************************************************************/ #ifndef THREAD_LOCAL_H #define THREAD_LOCAL_H #ifdef HAVE_CXX11_THREAD_LOCAL #define _THREAD_LOCAL_(m_t) thread_local m_t #else #if !defined(__GNUC__) && !defined(_MSC_VER) #error Platform or compiler not supported #endif #ifdef __GNUC__ #ifdef HAVE_GCC___THREAD #define _THREAD_LOCAL_(m_t) __thread m_t #else #define USE_CUSTOM_THREAD_LOCAL #endif #elif _MSC_VER #ifdef HAVE_DECLSPEC_THREAD #define _THREAD_LOCAL_(m_t) __declspec(thread) m_t #else #define USE_CUSTOM_THREAD_LOCAL #endif #endif // __GNUC__ _MSC_VER #endif // HAVE_CXX11_THREAD_LOCAL #ifdef USE_CUSTOM_THREAD_LOCAL #define _THREAD_LOCAL_(m_t) ThreadLocal #endif #include "core/typedefs.h" #ifdef WINDOWS_ENABLED #define _CALLBACK_FUNC_ __stdcall #else #define _CALLBACK_FUNC_ #endif struct ThreadLocalStorage { void *get_value() const; void set_value(void *p_value) const; void alloc(void (_CALLBACK_FUNC_ *p_dest_callback)(void *)); void free(); private: struct Impl; Impl *pimpl; }; template class ThreadLocal { ThreadLocalStorage storage; T init_val; static void _CALLBACK_FUNC_ destr_callback(void *tls_data) { memdelete(static_cast(tls_data)); } T *_tls_get_value() const { void *tls_data = storage.get_value(); if (tls_data) return static_cast(tls_data); T *data = memnew(T(init_val)); storage.set_value(data); return data; } public: ThreadLocal() : ThreadLocal(T()) {} ThreadLocal(const T &p_init_val) : init_val(p_init_val) { storage.alloc(&destr_callback); } ThreadLocal(const ThreadLocal &other) : ThreadLocal(*other._tls_get_value()) {} ~ThreadLocal() { storage.free(); } _FORCE_INLINE_ T *operator&() const { return _tls_get_value(); } _FORCE_INLINE_ operator T &() const { return *_tls_get_value(); } _FORCE_INLINE_ ThreadLocal &operator=(const T &val) { T *ptr = _tls_get_value(); *ptr = val; return *this; } }; struct FlagScopeGuard { FlagScopeGuard(bool &p_flag) : flag(p_flag) { flag = !flag; } ~FlagScopeGuard() { flag = !flag; } private: bool &flag; }; #undef _CALLBACK_FUNC_ #define _TLS_RECURSION_GUARD_V_(m_ret) \ static _THREAD_LOCAL_(bool) _recursion_flag_ = false; \ if (_recursion_flag_) \ return m_ret; \ FlagScopeGuard _recursion_guard_(_recursion_flag_); #define _TLS_RECURSION_GUARD_ \ static _THREAD_LOCAL_(bool) _recursion_flag_ = false; \ if (_recursion_flag_) \ return; \ FlagScopeGuard _recursion_guard_(_recursion_flag_); #endif // THREAD_LOCAL_H