apollo::perception::lib::ThreadWorker类 参考

#include <thread_worker.h>

apollo::perception::lib::ThreadWorker 的协作图:

Public 成员函数
	ThreadWorker ()=default
	~ThreadWorker ()
void	Bind (const std::function< bool()> &func)
void	Start ()
void	WakeUp ()
void	Join ()
void	Release ()

详细描述

在文件 thread_worker.h 第 27 行定义.

构造及析构函数说明

ThreadWorker()

apollo::perception::lib::ThreadWorker::ThreadWorker ( )

default

~ThreadWorker()

apollo::perception::lib::ThreadWorker::~ThreadWorker ( )

inline

在文件 thread_worker.h 第 30 行定义.

{ Release(); }

成员函数说明

Bind()

void apollo::perception::lib::ThreadWorker::Bind

(

const std::function< bool()> &

func

)

在文件 thread_worker.cc 第 22 行定义.

                                                       {
  work_func_ = func;
}

Join()

void apollo::perception::lib::ThreadWorker::Join

(

)

在文件 thread_worker.cc 第 43 行定义.

                        {
  std::unique_lock<std::mutex> lock(mutex_);
  condition_.wait(lock, [&]() { return !work_flag_; });
}

Release()

void apollo::perception::lib::ThreadWorker::Release

(

)

在文件 thread_worker.cc 第 48 行定义.

                           {
  if (thread_ptr_ == nullptr) {
    return;
  }
  {
    std::lock_guard<std::mutex> lock(mutex_);
    work_flag_ = true;
    exit_flag_ = true;
  }
  condition_.notify_one();
  thread_ptr_->join();
  thread_ptr_.reset(nullptr);
}

Start()

void apollo::perception::lib::ThreadWorker::Start

(

)

在文件 thread_worker.cc 第 26 行定义.

                         {
  if (thread_ptr_ == nullptr) {
    thread_ptr_.reset(new std::thread(&ThreadWorker::Core, this));
  }
  std::lock_guard<std::mutex> lock(mutex_);
  work_flag_ = false;
  exit_flag_ = false;
}

WakeUp()

void apollo::perception::lib::ThreadWorker::WakeUp

(

)

在文件 thread_worker.cc 第 35 行定义.

                          {
  {
    std::lock_guard<std::mutex> lock(mutex_);
    work_flag_ = true;
  }
  condition_.notify_one();
}

---

该类的文档由以下文件生成:

• modules/perception/common/lib/thread/thread_worker.h
• modules/perception/common/lib/thread/thread_worker.cc