apollo::cyber::scheduler::Processor类 参考

#include <processor.h>

apollo::cyber::scheduler::Processor 的协作图:

Public 成员函数
	Processor ()
virtual	~Processor ()
void	Run ()
void	Stop ()
void	BindContext (const std::shared_ptr< ProcessorContext > &context)
std::thread *	Thread ()
std::atomic< pid_t > &	Tid ()
std::shared_ptr< Snapshot >	ProcSnapshot ()

详细描述

在文件 processor.h 第 45 行定义.

构造及析构函数说明

Processor()

apollo::cyber::scheduler::Processor::Processor

(

)

在文件 processor.cc 第 36 行定义.

{ running_.store(true); }

~Processor()

apollo::cyber::scheduler::Processor::~Processor ( )

virtual

在文件 processor.cc 第 38 行定义.

{ Stop(); }

成员函数说明

BindContext()

void apollo::cyber::scheduler::Processor::BindContext

(

const std::shared_ptr< ProcessorContext > &

context

)

在文件 processor.cc 第 79 行定义.

                                                                          {
  context_ = context;
  std::call_once(thread_flag_,
                 [this]() { thread_ = std::thread(&Processor::Run, this); });
}

ProcSnapshot()

std::shared_ptr< Snapshot > apollo::cyber::scheduler::Processor::ProcSnapshot ( )

inline

在文件 processor.h 第 56 行定义.

{ return snap_shot_; }

Run()

void apollo::cyber::scheduler::Processor::Run

(

)

在文件 processor.cc 第 40 行定义.

                    {
  tid_.store(static_cast<int>(syscall(SYS_gettid)));
  AINFO << "processor_tid: " << tid_;
  snap_shot_->processor_id.store(tid_);
 
  while (cyber_likely(running_.load())) {
    if (cyber_likely(context_ != nullptr)) {
      auto croutine = context_->NextRoutine();
      if (croutine) {
        snap_shot_->execute_start_time.store(cyber::Time::Now().ToNanosecond());
        snap_shot_->routine_name = croutine->name();
        croutine->Resume();
        croutine->Release();
      } else {
        snap_shot_->execute_start_time.store(0);
        context_->Wait();
      }
    } else {
      std::unique_lock<std::mutex> lk(mtx_ctx_);
      cv_ctx_.wait_for(lk, std::chrono::milliseconds(10));
    }
  }
}

Stop()

void apollo::cyber::scheduler::Processor::Stop

(

)

在文件 processor.cc 第 64 行定义.

                     {
  if (!running_.exchange(false)) {
    return;
  }
 
  if (context_) {
    context_->Shutdown();
  }
 
  cv_ctx_.notify_one();
  if (thread_.joinable()) {
    thread_.join();
  }
}

Thread()

std::thread * apollo::cyber::scheduler::Processor::Thread ( )

inline

在文件 processor.h 第 53 行定义.

{ return &thread_; }

Tid()

std::atomic< pid_t > & apollo::cyber::scheduler::Processor::Tid

(

)

在文件 processor.cc 第 85 行定义.

                                 {
  while (tid_.load() == -1) {
    cpu_relax();
  }
  return tid_;
}

---

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

• cyber/scheduler/processor.h
• cyber/scheduler/processor.cc