fix(core): fix thread local is not supported in ios

GitOrigin-RevId: b7a6928f0bb8b7ac80b7526bbd28304dd6201330

src/core/impl/comp_node/cpu/comp_node.cpp

@@ -604,12 +604,8 @@ class CpuCompNode::CompNodeRecorderImpl final : public CompNodeBaseImpl {
         using EventImpl::EventImpl;
     };
 
-//! TODO: because the x-code bug, see
-//! https://github.com/tensorflow/tensorflow/issues/18356
-//! thread local is no support on IOS,
-//! When update x-xode, this code should be deleted
-#if !defined(IOS) && MGB_HAVE_THREAD
-    static thread_local SeqRecorderImpl* sm_cur_recorder;
+#if MGB_HAVE_THREAD
+    static MGB_THREAD_LOCAL_PTR(SeqRecorderImpl) sm_cur_recorder;
 #else
     SeqRecorderImpl* sm_cur_recorder = nullptr;
 #endif
@@ -822,9 +818,9 @@ public:
     }
 };
 MGB_DYN_TYPE_OBJ_FINAL_IMPL(CompNodeRecorderImpl);
-#if !defined(IOS) && MGB_HAVE_THREAD
-thread_local CpuCompNode::SeqRecorderImpl*
-        CompNodeRecorderImpl::sm_cur_recorder = nullptr;
+#if MGB_HAVE_THREAD
+MGB_THREAD_LOCAL_PTR(CpuCompNode::SeqRecorderImpl)
+CompNodeRecorderImpl::sm_cur_recorder = nullptr;
 #endif
 
 /* ======================== CpuCompNode ======================== */

src/core/include/megbrain/utils/thread.h

@@ -14,6 +14,7 @@
 #include "megbrain_build_config.h"
 #if MGB_HAVE_THREAD
 #include "./thread_impl_1.h"
+#include "./thread_local.h"
 #else
 #include "./thread_impl_0.h"
 #endif

src/core/include/megbrain/utils/thread_local.h

+/**
+ * \file src/core/include/megbrain/utils/thread_local.h
+ * MegEngine is Licensed under the Apache License, Version 2.0 (the "License")
+ *
+ * Copyright (c) 2014-2021 Megvii Inc. All rights reserved.
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT ARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ */
+
+#pragma once
+#include <cstddef>
+#include <functional>
+#include <thread>
+
+#if !defined(__APPLE__)
+#define USE_STL_THREAD_LOCAL 1
+#else
+#define USE_STL_THREAD_LOCAL 0
+#endif
+
+// clang-format off
+#if defined(__APPLE__)
+#   if (__ENVIRONMENT_MAC_OS_X_VERSION_MIN_REQUIRED__ + 0) >= 101000
+#       define USE_STL_THREAD_LOCAL 1
+#   else
+#       define USE_STL_THREAD_LOCAL 0
+#   endif
+#endif
+
+#if USE_STL_THREAD_LOCAL
+#define MGB_THREAD_LOCAL_PTR(T) thread_local T*
+#else
+#define MGB_THREAD_LOCAL_PTR(T) ThreadLocalPtr<T>
+#endif
+// clang-format on
+
+#if !USE_STL_THREAD_LOCAL
+#include <pthread.h>
+
+namespace mgb {
+
+template <typename T>
+class ThreadLocalPtr {
+    struct ThreadData {
+        const ThreadLocalPtr* self = nullptr;
+        T** data = nullptr;
+    };
+    pthread_key_t m_key;
+    std::function<T**()> m_constructor = nullptr;
+    std::function<void(T**)> m_destructor = nullptr;
+
+    void move_to(T** data) {
+        if(void* d = pthread_getspecific(m_key)){
+            *data = *static_cast<ThreadData*>(d)->data;
+        }
+    }
+
+    T** get() const {
+        if (auto d = pthread_getspecific(m_key)) {
+            return static_cast<ThreadData*>(d)->data;
+        }
+        ThreadData* t_data = new ThreadData();
+        t_data->data = m_constructor();
+        t_data->self = this;
+        pthread_setspecific(m_key, t_data);
+        return t_data->data;
+    }
+
+    static void exit(void* d) {
+        ThreadData* td = static_cast<ThreadData*>(d);
+        if (td && td->self->m_destructor)
+            td->self->m_destructor(td->data);
+        delete td;
+    }
+
+public:
+    ThreadLocalPtr(
+            std::function<T**()> constructor,
+            std::function<void(T**)> destructor = std::default_delete<T*>())
+            : m_constructor(constructor), m_destructor(destructor) {
+        pthread_key_create(&m_key, exit);
+    }
+
+    ThreadLocalPtr()
+            : ThreadLocalPtr(std::function<T**()>([] { return new T*(); })) {}
+
+    ThreadLocalPtr(std::nullptr_t)
+            : ThreadLocalPtr([] { return new T*(nullptr); }) {}
+
+    ThreadLocalPtr(ThreadLocalPtr&& other) : ThreadLocalPtr() {
+        other.move_to(get());
+    }
+
+    ThreadLocalPtr& operator=(ThreadLocalPtr&& other) {
+        other.move_to(get());
+        return *this;
+    }
+    ThreadLocalPtr& operator=(T* v) {
+        *get() = v;
+        return *this;
+    }
+    ~ThreadLocalPtr() { pthread_key_delete(m_key); }
+
+    //!& operator like std thread_local
+    T** operator&() const { return get(); }
+
+    //! use in if()
+    operator bool() const { return *get(); }
+
+    //! directly access its member
+    T* operator->() const { return *get(); }
+
+    //! convert to T*
+    operator T*() const { return *get(); }
+};
+
+}  // namespace mgb
+
+#endif
+
+// vim: syntax=cpp.doxygen foldmethod=marker foldmarker=f{{{,f}}}