threadspawner.cc

Go to the documentation of this file.

#include "ion/base/threadspawner.h"

namespace ion {
namespace base {

namespace {

static bool NamingThreadFunc(const std::string& name,
                             const port::ThreadStdFunc& user_func) {
  if (port::IsThreadNamingSupported())
    port::SetThreadName(name);
  return user_func();
}

}  // anonymous namespace

ThreadSpawner::ThreadSpawner(const std::string& name,
                             port::ThreadFuncPtr func_ptr)
    : name_(name),
      func_(func_ptr ? std::bind(NamingThreadFunc, name,
                                 port::ThreadStdFunc(func_ptr))
                     : port::ThreadStdFunc()),
      id_(Spawn()) {
}

ThreadSpawner::ThreadSpawner(const std::string& name,
                             const port::ThreadStdFunc& func)
    : name_(name),
      func_(std::bind(NamingThreadFunc, name, func)),
      id_(Spawn()) {
}

ThreadSpawner::~ThreadSpawner() {
  Join();
}

void ThreadSpawner::Join() {
  if (id_ != port::kInvalidThreadId) {
    port::ThreadId id = id_;
    id_ = port::kInvalidThreadId;
    port::JoinThread(id);
  }
}

port::ThreadId ThreadSpawner::Spawn() {
  if (func_)
    return port::SpawnThreadStd(&func_);
  else
    return port::kInvalidThreadId;
}


}  // namespace base
}  // namespace ion