Method SuperviseThread

be/src/util/thread.cc:359–399

[[clang::optnone]]
#elif defined(__GNUC__)
__attribute__((optimize("O0")))
#endif
void Thread::SuperviseThread(const char* name, const string& category,
    const Thread::ThreadFunctor& functor, const ThreadDebugInfo* parent_thread_info,
    Promise<int64_t>* thread_started) {
  int64_t system_tid = syscall(SYS_gettid);
  if (system_tid == -1) {
    string error_msg = GetStrErrMsg();
    LOG_EVERY_N(INFO, 100) << "Could not determine thread ID: " << error_msg;
  }
  // Store the final thread name in thread-local storage so the name pointer remains
  // valid for pstack/gdb throughout the thread's lifetime, even if the Thread object
  // that originally held the name gets destroyed (e.g., after Join() or Detach()).
  thread_local string tls_name;
  tls_name = (name == nullptr || name[0] == '\0')
      ? Substitute("thread-$0", system_tid)
      : string(name);
  // Keep const char* parameter pointing at thread-local storage for pstack visibility.
  name = tls_name.c_str();

  // Make a copy, since we want to refer to these variables after the unsafe point below.
  string category_copy = category.empty() ? "no-category" : category;
  shared_ptr<ThreadMgr> thread_mgr_ref = thread_manager;

  // Use boost's get_id rather than the system thread ID as the unique key for this thread
  // since the latter is more prone to being recycled.
  thread_mgr_ref->AddThread(this_thread::get_id(), tls_name, category_copy, system_tid);

  ThreadDebugInfo thread_debug_info;
  thread_debug_info.SetThreadName(tls_name);
  thread_debug_info.SetParentInfo(parent_thread_info);

  thread_started->Set(system_tid);

  // Any reference to any parameter not copied in by value may no longer be valid after
  // this point, since the caller that is waiting on *tid != 0 may wake, take the lock and
  // destroy the enclosing Thread object.

  functor();
  thread_mgr_ref->RemoveThread(this_thread::get_id(), category_copy);
}

void ThreadGroup::AddThread(unique_ptr<Thread>&& thread) {
  threads_.emplace_back(move(thread));