Method _execute_tasks_pthread

src/bthread/execution_queue.cpp:210–230

}

void* ExecutionQueueBase::_execute_tasks_pthread(void* arg) {
    butil::PlatformThread::SetNameSimple("ExecutionQueue");
    auto head = (TaskNode*)arg;
    auto m = (ExecutionQueueBase*)head->q;
    m->_current_head = head;
    while (true) {
        BAIDU_SCOPED_LOCK(m->_mutex);
        while (!m->_current_head) {
            m->_cond.Wait();
        }
        _execute_tasks(m->_current_head);
        m->_current_head = NULL;

        int expected = _version_of_id(m->_this_id);
        if (expected != m->_join_butex->load(butil::memory_order_relaxed)) {
            // Execute queue has been stopped and stopped task has been executed, quit.
            break;
        }
    }
    return NULL;
}

void ExecutionQueueBase::return_task_node(TaskNode* node) {
    node->clear_before_return(_clear_func);