Home
last modified time | relevance | path

Searched refs:taskQueue (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/
H A Dthread_linux.c39 Queue *taskQueue; member
77 int fd = QueueGetDequeueFd(thread->taskQueue); in ThreadStartFunc()
78 …ReactorItem *reactorItem = ReactorRegister(thread->reactor, fd, (void *)thread->taskQueue, ReadyTo… in ThreadStartFunc()
88 TaskItem *task = (TaskItem *)QueueTryDequeue(thread->taskQueue); in ThreadStartFunc()
92 task = (TaskItem *)QueueTryDequeue(thread->taskQueue); in ThreadStartFunc()
135 thread->taskQueue = QueueCreate(THREAD_QUEUE_SIZE); in ThreadCreate()
136 if (thread->taskQueue == NULL) { in ThreadCreate()
170 QueueDelete(thread->taskQueue, free); in ThreadCreate()
185 QueueDelete(thread->taskQueue, free); in ThreadDelete()
202 QueueEnqueue(thread->taskQueue, task); in ThreadPostTask()
/ohos5.0/drivers/hdf_core/framework/core/host/src/
H A Dhdf_power_manager.c18 struct HdfTaskQueue *taskQueue; member
31 if (pmTaskQueue->taskQueue == NULL) { in HdfPmTaskQueueInit()
32 pmTaskQueue->taskQueue = HdfTaskQueueCreate(func, "pm_queue"); in HdfPmTaskQueueInit()
33 if (pmTaskQueue->taskQueue != NULL) { in HdfPmTaskQueueInit()
44 HdfTaskQueueDestroy(pmTaskQueue->taskQueue); in HdfPmTaskQueueDestroy()
45 pmTaskQueue->taskQueue = NULL; in HdfPmTaskQueueDestroy()
91 HdfTaskEnqueue(pmTaskQueue->taskQueue, &pmRequest->task); in HdfPmTaskPut()
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/
H A Dbtm_thread.c207 Queue *taskQueue = NULL; in BTM_DeleteProcessingQueue() local
212 taskQueue = queue->queue; in BTM_DeleteProcessingQueue()
220 if (taskQueue != NULL) { in BTM_DeleteProcessingQueue()
221 RunAllTaskInQueue(taskQueue); in BTM_DeleteProcessingQueue()
222 QueueDelete(taskQueue, FreeTask); in BTM_DeleteProcessingQueue()
223 taskQueue = NULL; in BTM_DeleteProcessingQueue()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dtask_pool_impl.cpp259 TaskQueue *taskQueue = nullptr; in TaskWorker() local
262 GetTask(task, taskQueue); in TaskWorker()
269 FinishExecuteTask(taskQueue); in TaskWorker()
275 void TaskPoolImpl::FinishExecuteTask(TaskQueue *taskQueue) in FinishExecuteTask() argument
278 if (taskQueue != nullptr) { in FinishExecuteTask()
279 taskQueue->ReleaseLock(); in FinishExecuteTask()
H A Dtask_pool_impl.h62 void FinishExecuteTask(TaskQueue *taskQueue);
/ohos5.0/foundation/ability/form_fwk/services/src/
H A Dform_render_mgr.cpp203 std::unordered_map<int64_t, std::function<void()>> taskQueue; in AddAcquireProviderForbiddenTask() local
204 taskQueue.emplace(formId, task); in AddAcquireProviderForbiddenTask()
205 forbiddenTaskMap_.emplace(bundleName, taskQueue); in AddAcquireProviderForbiddenTask()
216 std::unordered_map<int64_t, std::function<void()>> taskQueue; in ExecAcquireProviderForbiddenTask() local
223 taskQueue = search->second; in ExecAcquireProviderForbiddenTask()
226 auto iter = taskQueue.begin(); in ExecAcquireProviderForbiddenTask()
227 while (iter != taskQueue.end()) { in ExecAcquireProviderForbiddenTask()
231 iter = taskQueue.erase(iter); in ExecAcquireProviderForbiddenTask()
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_manager.h179 …std::pair<uint64_t, Priority> GetTaskByPriority(const std::unique_ptr<ExecuteQueue>& taskQueue, Pr…
H A Dtask_manager.cpp76 std::unique_ptr<ExecuteQueue> taskQueue = std::make_unique<ExecuteQueue>(); in TaskManager() local
77 taskQueues_[i] = std::move(taskQueue); in TaskManager()
824 …<uint64_t, Priority> TaskManager::GetTaskByPriority(const std::unique_ptr<ExecuteQueue>& taskQueue, in GetTaskByPriority() argument
827 uint64_t taskId = taskQueue->DequeueTaskId(); in GetTaskByPriority()