{

std::lock_guard<std::recursive_mutex> g(lock_);

run_in_loop_func_queue_.push_back(func);

if (sp_run_read_event_ == nullptr)

return;

commitRunRequest();

{

if (!isInLoopThread()) {

LogWarn("Fail, use runInLoop() instead.");

return;

}

run_next_func_queue_.push_back(func);

{

if (isInLoopThread())

run_next_func_queue_.push_back(func);

else

runInLoop(func);

{

while (!run_next_func_queue_.empty()) {

Func &func = run_next_func_queue_.front();

if (func) {

++cb_level_;

func();

--cb_level_;

}

run_next_func_queue_.pop_front();

}

{

/**

std::deque<Func> tmp;

{

std::lock_guard<std::recursive_mutex> g(lock_);

run_in_loop_func_queue_.swap(tmp);

finishRunRequest();

}

while (!tmp.empty()) {

Func &func = tmp.front();

if (func) {

++cb_level_;

func();

--cb_level_;

handleNextFunc();

}

tmp.pop_front();

}

{

int remain_loop_count = 10; //! 限定次数，防止出现 runNext() 递归导致无法退出循环的问题

while ((!run_in_loop_func_queue_.empty() || !run_next_func_queue_.empty())

&& remain_loop_count-- > 0) {

std::deque<Func> tasks = std::move(run_next_func_queue_);

tasks.insert(tasks.end(), run_in_loop_func_queue_.begin(), run_in_loop_func_queue_.end());

run_in_loop_func_queue_.clear();

while (!tasks.empty()) {

Func &func = tasks.front();

if (func) {

++cb_level_;

func();

--cb_level_;

}

tasks.pop_front();

}

}

if (remain_loop_count == 0)

LogWarn("found recursive actions, force quit");

{

if (!has_commit_run_req_) {

char ch = 0;

ssize_t wsize = write(run_write_fd_, &ch, 1);

(void)wsize;

has_commit_run_req_ = true;

}

{

char ch = 0;

ssize_t rsize = read(run_read_fd_, &ch, 1);

(void)rsize;

has_commit_run_req_ = false;