libxr/_webots_2async_8cpp_source.html

#include "async.hpp"


#include "libxr_def.hpp"

#include "thread.hpp"


using namespace LibXR;


ASync::ASync(size_t stack_depth, Thread::Priority priority) {

  thread_handle_.Create(this, ThreadFun, "async_job", stack_depth, priority);

}


ErrorCode ASync::AssignJob(Callback job) {

  if (status_ == Status::BUSY) {

    return ErrorCode::BUSY;

  }


  status_ = Status::BUSY;


  job_ = job;

  sem_.Post();


  return ErrorCode::OK;

}

LibXR::ASync::status_
Status status_
当前异步任务状态。 The current status of the asynchronous task.
Definition async.hpp:69

LibXR::ASync::Status::BUSY
@ BUSY
任务正在执行中。 Task is currently running.

LibXR::ASync::thread_handle_
Thread thread_handle_
处理异步任务的线程。 Thread handling asynchronous tasks.
Definition async.hpp:140

LibXR::ASync::ASync
ASync(size_t stack_depth, Thread::Priority priority)
构造 ASync 对象并初始化任务线程。 Constructs an ASync object and initializes the task thread.
Definition async.cpp:7

LibXR::ASync::sem_
Semaphore sem_
控制任务执行的信号量。 Semaphore controlling task execution.
Definition async.hpp:138

LibXR::ASync::ThreadFun
static void ThreadFun(ASync *async)
任务线程函数，等待信号量并执行任务。 Task thread function that waits for a semaphore and executes the assigned job.
Definition async.hpp:57

LibXR::ASync::AssignJob
ErrorCode AssignJob(Callback job)
分配一个异步任务并准备执行。 Assigns an asynchronous job and prepares for execution.
Definition async.cpp:11

LibXR::ASync::job_
Callback job_
存储分配的异步任务回调。 Stores the assigned asynchronous job callback.
Definition async.hpp:137

LibXR::Callback
提供一个通用的回调包装，支持动态参数传递。 Provides a generic callback wrapper, supporting dynamic argument passing.
Definition libxr_cb.hpp:125

LibXR::Semaphore::Post
void Post()
释放（增加）信号量 Releases (increments) the semaphore
Definition semaphore.cpp:13

LibXR::Thread::Priority
Priority
线程优先级枚举 Enumeration for thread priorities
Definition thread.hpp:22

LibXR::Thread::Create
void Create(ArgType arg, void(*function)(ArgType arg), const char *name, size_t stack_depth, Thread::Priority priority)
创建新线程 Creates a new thread
Definition thread.hpp:64

LibXR
LibXR Color Control Library / LibXR终端颜色控制库
Definition esp_gpio.hpp:8

LibXR::min
constexpr auto min(T1 a, T2 b) -> typename std::common_type< T1, T2 >::type
计算两个数的最小值
Definition libxr_def.hpp:161