Lines Matching refs:priority
150 napi_value priority = NapiHelper::CreateUint32(env, static_cast<uint32_t>(worker->priority_));
166 napi_set_named_property(env, threadInfo, "priority", priority);
635 EraseWaitingTaskId(task->taskId_, task->currentTaskInfo_->priority);
718 void TaskManager::IncreaseNumIfNoIdle(Priority priority)
720 if (priority != Priority::IDLE) {
725 void TaskManager::DecreaseNumIfNoIdle(Priority priority)
727 if (priority != Priority::IDLE) {
738 void TaskManager::EnqueueTaskId(uint64_t taskId, Priority priority)
742 IncreaseNumIfNoIdle(priority);
743 taskQueues_[priority]->EnqueueTaskId(taskId);
757 void TaskManager::EraseWaitingTaskId(uint64_t taskId, Priority priority)
760 if (!taskQueues_[priority]->EraseWaitingTaskId(taskId)) {
810 Priority priority)
814 EnqueuePendingTaskInfo(taskId, priority);
815 return std::make_pair(0, priority);
817 DecreaseNumIfNoIdle(priority);
818 return std::make_pair(taskId, priority);
1151 void TaskManager::EnqueuePendingTaskInfo(uint64_t taskId, Priority priority)
1157 pendingTaskInfos_.emplace(taskId, priority);
1446 bool TaskManager::PostTask(std::function<void()> task, const char* taskName, Priority priority)
1448 return mainThreadHandler_->PostTask(task, taskName, 0, TASK_EVENTHANDLER_PRIORITY_MAP.at(priority));
1558 TaskManager::GetInstance().EraseWaitingTaskId(task->taskId_, task->currentTaskInfo_->priority);
1706 const std::string &name, uint32_t priority)
1713 // refresh priority default values on first creation
1715 seqRunner->priority_ = static_cast<Priority>(priority);
1722 if (priority != seqRunner->priority_) {
1723 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "seqRunner:: priority can not changed.");