chromium/base/task/sequence_manager/work_queue.cc

// Copyright 2015 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "base/task/sequence_manager/work_queue.h"

#include <optional>

#include "base/debug/alias.h"
#include "base/task/sequence_manager/fence.h"
#include "base/task/sequence_manager/sequence_manager_impl.h"
#include "base/task/sequence_manager/task_order.h"
#include "base/task/sequence_manager/work_queue_sets.h"
#include "build/build_config.h"
#include "third_party/abseil-cpp/absl/container/inlined_vector.h"

namespace base {
namespace sequence_manager {
namespace internal {

WorkQueue::WorkQueue(TaskQueueImpl* task_queue,
                     const char* name,
                     QueueType queue_type)
    : … { … }

Value::List WorkQueue::AsValue(TimeTicks now) const { … }

WorkQueue::~WorkQueue() { … }

const Task* WorkQueue::GetFrontTask() const { … }

const Task* WorkQueue::GetBackTask() const { … }

bool WorkQueue::BlockedByFence() const { … }

std::optional<TaskOrder> WorkQueue::GetFrontTaskOrder() const { … }

void WorkQueue::Push(Task task) { … }

WorkQueue::TaskPusher::TaskPusher(WorkQueue* work_queue)
    : … { … }

WorkQueue::TaskPusher::TaskPusher(TaskPusher&& other)
    : … { … }

void WorkQueue::TaskPusher::Push(Task task) { … }

WorkQueue::TaskPusher::~TaskPusher() { … }

WorkQueue::TaskPusher WorkQueue::CreateTaskPusher() { … }

void WorkQueue::PushNonNestableTaskToFront(Task task) { … }

void WorkQueue::TakeImmediateIncomingQueueTasks() { … }

Task WorkQueue::TakeTaskFromWorkQueue() { … }

bool WorkQueue::RemoveAllCanceledTasksFromFront() { … }

void WorkQueue::AssignToWorkQueueSets(WorkQueueSets* work_queue_sets) { … }

void WorkQueue::AssignSetIndex(size_t work_queue_set_index) { … }

bool WorkQueue::InsertFenceImpl(Fence fence) { … }

void WorkQueue::InsertFenceSilently(Fence fence) { … }

bool WorkQueue::InsertFence(Fence fence) { … }

bool WorkQueue::RemoveFence() { … }

void WorkQueue::MaybeShrinkQueue() { … }

void WorkQueue::PopTaskForTesting() { … }

void WorkQueue::CollectTasksOlderThan(TaskOrder reference,
                                      std::vector<const Task*>* result) const { … }

}  // namespace internal
}  // namespace sequence_manager
}  // namespace base