Searched refs:mTaskQueue (Results 1 – 4 of 4) sorted by relevance
53 if (mTaskQueue.empty()) { in threadLoop()60 } else if (mTaskQueue.empty()) { in threadLoop()66 task = mTaskQueue.front(); in threadLoop()67 mTaskQueue.pop(); in threadLoop()84 if (!mTaskQueue.empty()) { in threadLoop()85 LOG(WARNING) << mTaskQueue.size() << " tasks are ignored."; in threadLoop()98 mTaskQueue.push(task); in enqueue()
44 std::queue<Task> mTaskQueue GUARDED_BY(mLock);
83 private final PriorityBlockingQueue<ScriptExecutionTask> mTaskQueue = field in DataBrokerImpl270 mTaskQueue.removeIf(task -> task.isAssociatedWithMetricsConfig(key)); in removeMetricsConfig()277 mTaskQueue.clear(); in removeAllMetricsConfigs()285 mTaskQueue.add(task); in addTaskToQueue()335 return mTaskQueue; in getTaskQueue()350 ScriptExecutionTask task = mTaskQueue.peek(); in pollAndExecuteTask()361 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()