Searched refs:taskQueue_ (Results 1 – 4 of 4) sorted by relevance
51 taskQueue_.resize(THREAD_POOL_MAX_TASKS); in Init()52 for (size_t t = 0; t < taskQueue_.size(); ++t) { in Init()53 taskQueue_[t].available = true; in Init()55 taskQueue_[t].subTaskFlag.emplace_back(new std::atomic_bool { false }); in Init()68 if (*taskQueue_[k].subTaskFlag[threadIndex]) { in ThreadRun()69 taskQueue_[k].task.processor(threadIndex); in ThreadRun()70 *taskQueue_[k].subTaskFlag[threadIndex] = false; in ThreadRun()87 for (auto& task : taskQueue_) { in ~ThreadPool()132 taskQueue_[index].available = true; in AddNewTask()139 if (taskQueue_[i].available) { in AcquireWorkIndex()[all …]
70 std::vector<TaskNode> taskQueue_; variable
64 taskQueue_.push(TaskEvent(priority, targetTime, task, name)); in AddTask()65 taskQueue_.ShrinkIfNeedLocked(); in AddTask()67 if (taskQueue_.size() > 1000) { // 1000: 积压超过1000条预警 in AddTask()68 … HIVIEW_LOGW("%{public}s AddTask. runTask size is %{public}d", name_.c_str(), taskQueue_.size()); in AddTask()74 if (taskQueue_.empty()) { in ObtainTask()78 auto tmp = taskQueue_.top(); in ObtainTask()117 taskQueue_.pop(); in TaskCallback()119 …EW_LOGW("task == nullptr. %{public}s runTask size is %{public}d", name.c_str(), taskQueue_.size()); in TaskCallback()
85 EventPriorityQueue<TaskEvent> taskQueue_; variable