adac219925
bind.h, callback.h, callback_forward.h, and callback_helpers.h moved into /base/functional/. Update the include paths to directly include them in their new location. Bug: 1364441 Change-Id: I32ec425b9c0e52ec4b50047bf3290fecc5c905ff Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/4148554 Reviewed-by: Daniel Cheng <dcheng@chromium.org> Auto-Submit: Avi Drissman <avi@chromium.org> Owners-Override: Avi Drissman <avi@chromium.org> Owners-Override: Daniel Cheng <dcheng@chromium.org> Commit-Queue: Daniel Cheng <dcheng@chromium.org> Cr-Commit-Position: refs/heads/main@{#1091567}
84 lines
2.6 KiB
C++
84 lines
2.6 KiB
C++
// Copyright 2013 The Chromium Authors
|
|
// Use of this source code is governed by a BSD-style license that can be
|
|
// found in the LICENSE file.
|
|
|
|
#include "content/browser/startup_task_runner.h"
|
|
|
|
#include "base/functional/bind.h"
|
|
#include "base/location.h"
|
|
#include "base/metrics/histogram_macros.h"
|
|
#include "base/task/single_thread_task_runner.h"
|
|
|
|
namespace content {
|
|
|
|
StartupTaskRunner::StartupTaskRunner(
|
|
base::OnceCallback<void(int)> startup_complete_callback,
|
|
scoped_refptr<base::SingleThreadTaskRunner> proxy)
|
|
: startup_complete_callback_(std::move(startup_complete_callback)),
|
|
proxy_(proxy) {}
|
|
|
|
StartupTaskRunner::~StartupTaskRunner() {}
|
|
|
|
void StartupTaskRunner::AddTask(StartupTask callback) {
|
|
task_list_.push_back(std::move(callback));
|
|
}
|
|
|
|
void StartupTaskRunner::StartRunningTasksAsync() {
|
|
DCHECK(proxy_.get());
|
|
int result = 0;
|
|
if (task_list_.empty()) {
|
|
if (!startup_complete_callback_.is_null()) {
|
|
std::move(startup_complete_callback_).Run(result);
|
|
}
|
|
} else {
|
|
base::OnceClosure next_task =
|
|
base::BindOnce(&StartupTaskRunner::WrappedTask, base::Unretained(this));
|
|
last_wrapped_task_post_time_ = base::TimeTicks::Now();
|
|
proxy_->PostNonNestableTask(FROM_HERE, std::move(next_task));
|
|
}
|
|
}
|
|
|
|
void StartupTaskRunner::RunAllTasksNow() {
|
|
int result = 0;
|
|
for (auto it = task_list_.begin(); it != task_list_.end(); it++) {
|
|
result = std::move(*it).Run();
|
|
if (result > 0) break;
|
|
}
|
|
task_list_.clear();
|
|
if (!startup_complete_callback_.is_null()) {
|
|
std::move(startup_complete_callback_).Run(result);
|
|
}
|
|
}
|
|
|
|
void StartupTaskRunner::WrappedTask() {
|
|
if (task_list_.empty()) {
|
|
// This will happen if the remaining tasks have been run synchronously since
|
|
// the WrappedTask was created. Any callback will already have been called,
|
|
// so there is nothing to do
|
|
return;
|
|
}
|
|
|
|
// Log the time that this task spent queued.
|
|
UMA_HISTOGRAM_TIMES("Startup.StartupTaskRunner.AsyncTaskQueueTime",
|
|
base::TimeTicks::Now() - last_wrapped_task_post_time_);
|
|
|
|
int result = std::move(task_list_.front()).Run();
|
|
task_list_.pop_front();
|
|
if (result > 0) {
|
|
// Stop now and throw away the remaining tasks
|
|
task_list_.clear();
|
|
}
|
|
if (task_list_.empty()) {
|
|
if (!startup_complete_callback_.is_null()) {
|
|
std::move(startup_complete_callback_).Run(result);
|
|
}
|
|
} else {
|
|
base::OnceClosure next_task =
|
|
base::BindOnce(&StartupTaskRunner::WrappedTask, base::Unretained(this));
|
|
last_wrapped_task_post_time_ = base::TimeTicks::Now();
|
|
proxy_->PostNonNestableTask(FROM_HERE, std::move(next_task));
|
|
}
|
|
}
|
|
|
|
} // namespace content
|