Searched refs:mTaskQueue (Results 1 – 4 of 4) sorted by relevance
57 if (mTaskQueue.empty()) { in threadLoop()64 } else if (mTaskQueue.empty()) { in threadLoop()70 task = mTaskQueue.front(); in threadLoop()71 mTaskQueue.pop(); in threadLoop()88 if (!mTaskQueue.empty()) { in threadLoop()89 LOG(WARNING) << mTaskQueue.size() << " tasks are ignored."; in threadLoop()102 mTaskQueue.push(task); in enqueue()
42 std::queue<Task> mTaskQueue GUARDED_BY(mLock);
102 private final PriorityBlockingQueue<ScriptExecutionTask> mTaskQueue = field in DataBrokerImpl353 Iterator<ScriptExecutionTask> it = mTaskQueue.iterator(); in removeMetricsConfig()357 mTaskQueue.remove(task); in removeMetricsConfig()369 mTaskQueue.clear(); in removeAllMetricsConfigs()378 mTaskQueue.add(task); in addTaskToQueue()438 return mTaskQueue; in getTaskQueue()454 ScriptExecutionTask task = mTaskQueue.peek(); in pollAndExecuteTask()466 mTaskQueue.poll(); // remove task from queue in pollAndExecuteTask()
285 private final Queue<Message> mTaskQueue = new LinkedList<>(); field in RemoteVvmTaskManager.RemoteServiceConnection295 mTaskQueue.add(message); in enqueue()323 Message message = mTaskQueue.poll(); in runQueue()333 message = mTaskQueue.poll(); in runQueue()