Lines Matching refs:IncomingTaskQueue
40 IncomingTaskQueue::IncomingTaskQueue(
49 IncomingTaskQueue::~IncomingTaskQueue() = default;
51 bool IncomingTaskQueue::AddToIncomingQueue(const Location& from_here,
81 void IncomingTaskQueue::Shutdown() {
86 void IncomingTaskQueue::ReportMetricsOnIdle() const {
92 IncomingTaskQueue::TriageQueue::TriageQueue(IncomingTaskQueue* outer)
95 IncomingTaskQueue::TriageQueue::~TriageQueue() = default;
97 const PendingTask& IncomingTaskQueue::TriageQueue::Peek() {
104 PendingTask IncomingTaskQueue::TriageQueue::Pop() {
113 bool IncomingTaskQueue::TriageQueue::HasTasks() {
119 void IncomingTaskQueue::TriageQueue::Clear() {
153 void IncomingTaskQueue::TriageQueue::ReloadFromIncomingQueueIfEmpty() {
160 IncomingTaskQueue::DelayedQueue::DelayedQueue() {
164 IncomingTaskQueue::DelayedQueue::~DelayedQueue() = default;
166 void IncomingTaskQueue::DelayedQueue::Push(PendingTask pending_task) {
175 const PendingTask& IncomingTaskQueue::DelayedQueue::Peek() {
181 PendingTask IncomingTaskQueue::DelayedQueue::Pop() {
194 bool IncomingTaskQueue::DelayedQueue::HasTasks() {
203 void IncomingTaskQueue::DelayedQueue::Clear() {
209 size_t IncomingTaskQueue::DelayedQueue::Size() const {
214 IncomingTaskQueue::DeferredQueue::DeferredQueue() {
218 IncomingTaskQueue::DeferredQueue::~DeferredQueue() = default;
220 void IncomingTaskQueue::DeferredQueue::Push(PendingTask pending_task) {
225 const PendingTask& IncomingTaskQueue::DeferredQueue::Peek() {
231 PendingTask IncomingTaskQueue::DeferredQueue::Pop() {
239 bool IncomingTaskQueue::DeferredQueue::HasTasks() {
244 void IncomingTaskQueue::DeferredQueue::Clear() {
250 bool IncomingTaskQueue::PostPendingTask(PendingTask* pending_task) {
281 bool IncomingTaskQueue::PostPendingTaskLockRequired(PendingTask* pending_task) {
296 void IncomingTaskQueue::ReloadWorkQueue(TaskQueue* work_queue) {
