apollo::cyber::scheduler::ClassicContext类 参考

#include <classic_context.h>

类 apollo::cyber::scheduler::ClassicContext 继承关系图:

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

Public 成员函数
	ClassicContext ()
	ClassicContext (const std::string &group_name)
std::shared_ptr< CRoutine >	NextRoutine () override
void	Wait () override
void	Shutdown () override

静态 Public 成员函数
static void	Notify (const std::string &group_name)
static bool	RemoveCRoutine (const std::shared_ptr< CRoutine > &cr)

静态 Public 属性
static CR_GROUP	cr_group_
static RQ_LOCK_GROUP	rq_locks_
static GRP_WQ_CV	cv_wq_
static GRP_WQ_MUTEX	mtx_wq_
static NOTIFY_GRP	notify_grp_

额外继承的成员函数
Protected 属性 继承自 apollo::cyber::scheduler::ProcessorContext
std::atomic< bool >	stop_ {false}

详细描述

在文件 classic_context.h 第 52 行定义.

构造及析构函数说明

ClassicContext() [1/2]

apollo::cyber::scheduler::ClassicContext::ClassicContext

(

)

在文件 classic_context.cc 第 37 行定义.

{ InitGroup(DEFAULT_GROUP_NAME); }

ClassicContext() [2/2]

apollo::cyber::scheduler::ClassicContext::ClassicContext ( const std::string &  group_name )

explicit

在文件 classic_context.cc 第 39 行定义.

                                                          {
  InitGroup(group_name);
}

成员函数说明

NextRoutine()

std::shared_ptr< CRoutine > apollo::cyber::scheduler::ClassicContext::NextRoutine ( )

overridevirtual

实现了 apollo::cyber::scheduler::ProcessorContext.

在文件 classic_context.cc 第 52 行定义.

                                                    {
  if (cyber_unlikely(stop_.load())) {
    return nullptr;
  }
 
  for (int i = MAX_PRIO - 1; i >= 0; --i) {
    ReadLockGuard<AtomicRWLock> lk(lq_->at(i));
    for (auto& cr : multi_pri_rq_->at(i)) {
      if (!cr->Acquire()) {
        continue;
      }
 
      if (cr->UpdateState() == RoutineState::READY) {
        return cr;
      }
 
      cr->Release();
    }
  }
 
  return nullptr;
}

Notify()

void apollo::cyber::scheduler::ClassicContext::Notify ( const std::string &  group_name )

static

在文件 classic_context.cc 第 92 行定义.

                                                       {
  (&mtx_wq_[group_name])->Mutex().lock();
  notify_grp_[group_name]++;
  (&mtx_wq_[group_name])->Mutex().unlock();
  cv_wq_[group_name].Cv().notify_one();
}

RemoveCRoutine()

bool apollo::cyber::scheduler::ClassicContext::RemoveCRoutine ( const std::shared_ptr< CRoutine > &  cr )

static

在文件 classic_context.cc 第 99 行定义.

                                                                     {
  auto grp = cr->group_name();
  auto prio = cr->priority();
  auto crid = cr->id();
  WriteLockGuard<AtomicRWLock> lk(ClassicContext::rq_locks_[grp].at(prio));
  auto& croutines = ClassicContext::cr_group_[grp].at(prio);
  for (auto it = croutines.begin(); it != croutines.end(); ++it) {
    if ((*it)->id() == crid) {
      auto cr = *it;
      cr->Stop();
      while (!cr->Acquire()) {
        std::this_thread::sleep_for(std::chrono::microseconds(1));
        AINFO_EVERY(1000) << "waiting for task " << cr->name() << " completion";
      }
      croutines.erase(it);
      cr->Release();
      return true;
    }
  }
  return false;
}

Shutdown()

void apollo::cyber::scheduler::ClassicContext::Shutdown ( )

overridevirtual

重载 apollo::cyber::scheduler::ProcessorContext .

在文件 classic_context.cc 第 84 行定义.

                              {
  stop_.store(true);
  mtx_wrapper_->Mutex().lock();
  notify_grp_[current_grp] = std::numeric_limits<unsigned char>::max();
  mtx_wrapper_->Mutex().unlock();
  cw_->Cv().notify_all();
}

Wait()

void apollo::cyber::scheduler::ClassicContext::Wait ( )

overridevirtual

实现了 apollo::cyber::scheduler::ProcessorContext.

在文件 classic_context.cc 第 75 行定义.

                          {
  std::unique_lock<std::mutex> lk(mtx_wrapper_->Mutex());
  cw_->Cv().wait_for(lk, std::chrono::milliseconds(1000),
                     [&]() { return notify_grp_[current_grp] > 0; });
  if (notify_grp_[current_grp] > 0) {
    notify_grp_[current_grp]--;
  }
}

类成员变量说明

cr_group_

CR_GROUP apollo::cyber::scheduler::ClassicContext::cr_group_

static

在文件 classic_context.h 第 64 行定义.

cv_wq_

GRP_WQ_CV apollo::cyber::scheduler::ClassicContext::cv_wq_

static

在文件 classic_context.h 第 66 行定义.

mtx_wq_

GRP_WQ_MUTEX apollo::cyber::scheduler::ClassicContext::mtx_wq_

static

在文件 classic_context.h 第 67 行定义.

notify_grp_

NOTIFY_GRP apollo::cyber::scheduler::ClassicContext::notify_grp_

static

在文件 classic_context.h 第 68 行定义.

rq_locks_

RQ_LOCK_GROUP apollo::cyber::scheduler::ClassicContext::rq_locks_

static

在文件 classic_context.h 第 65 行定义.

---

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

• cyber/scheduler/policy/classic_context.h
• cyber/scheduler/policy/classic_context.cc