0

Mass-migrate users of base::ThreadPool() as a trait to base::ThreadPool:: API [crypto/-net/]

Split directories [crypto/-net/] from
https://chromium-review.googlesource.com/c/chromium/src/+/2026350
as it had trouble landing in one go.

The following script was used to generate this CL (run on every C++
file in the codebase; processing .h before matching .cc/.mm):
https://bugs.chromium.org/p/chromium/issues/detail?id=1026641#c22
(intentionally ignores cleaning post_task.h for now).

TBR=fdoray@chromium.org

Bug: 1026641
Change-Id: I4b5f8071c38efd854ea581d3bb16d5e921866ca4
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/2074937
Reviewed-by: Gabriel Charette <gab@chromium.org>
Commit-Queue: Gabriel Charette <gab@chromium.org>
Cr-Commit-Position: refs/heads/master@{#744678}
This commit is contained in:
Gabriel Charette
2020-02-26 16:35:22 +00:00
committed by Commit Bot
parent e25c6e76a0
commit d5c656c575
117 changed files with 435 additions and 400 deletions
crypto
device
extensions/browser
headless/app
ios
jingle/glue
media
mojo/public/cpp
net

@ -29,6 +29,7 @@
#include "base/strings/string_piece.h"
#include "base/strings/stringprintf.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "base/threading/thread_checker.h"
#include "base/threading/thread_restrictions.h"
@ -206,10 +207,9 @@ class ChromeOSTokenManager {
std::unique_ptr<TPMModuleAndSlot> tpm_args(
new TPMModuleAndSlot(chaps_module_));
TPMModuleAndSlot* tpm_args_ptr = tpm_args.get();
base::PostTaskAndReply(
base::ThreadPool::PostTaskAndReply(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&ChromeOSTokenManager::InitializeTPMTokenInThreadPool,
system_slot_id, tpm_args_ptr),
base::BindOnce(
@ -360,10 +360,9 @@ class ChromeOSTokenManager {
std::unique_ptr<TPMModuleAndSlot> tpm_args(
new TPMModuleAndSlot(chaps_module_));
TPMModuleAndSlot* tpm_args_ptr = tpm_args.get();
base::PostTaskAndReply(
base::ThreadPool::PostTaskAndReply(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&ChromeOSTokenManager::InitializeTPMTokenInThreadPool,
slot_id, tpm_args_ptr),
base::BindOnce(&ChromeOSTokenManager::OnInitializedTPMForChromeOSUser,

@ -30,6 +30,7 @@
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_thread_priority.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/win/core_winrt_util.h"
@ -665,9 +666,8 @@ void BluetoothAdapterWinrt::Init(InitCallback init_cb) {
// Some of the initialization work requires loading libraries and should not
// be run on the browser main thread.
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&BluetoothAdapterWinrt::PerformSlowInitTasks),
base::BindOnce(&BluetoothAdapterWinrt::CompleteInitAgile,
weak_ptr_factory_.GetWeakPtr(), std::move(init_cb)));

@ -18,6 +18,7 @@
#include "base/sequenced_task_runner.h"
#include "base/task/cancelable_task_tracker.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "device/bluetooth/bluetooth_export.h"
@class NSDictionary;
@ -76,9 +77,8 @@ class DEVICE_BLUETOOTH_EXPORT BluetoothLowEnergyDeviceWatcherMac
// Thread runner to watch, read, and parse bluetooth property list file.
scoped_refptr<base::SequencedTaskRunner> file_thread_task_runner_ =
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN});
scoped_refptr<base::SequencedTaskRunner> ui_thread_task_runner_;
LowEnergyDeviceListUpdatedCallback low_energy_device_list_updated_callback_;

@ -18,6 +18,7 @@
#include "base/strings/stringprintf.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "device/bluetooth/bluetooth_classic_win.h"
#include "device/bluetooth/bluetooth_device.h"
#include "device/bluetooth/bluetooth_init_win.h"
@ -268,8 +269,8 @@ void BluetoothTaskManagerWin::RemoveObserver(Observer* observer) {
void BluetoothTaskManagerWin::Initialize() {
DCHECK(ui_task_runner_->RunsTasksInCurrentSequence());
InitializeWithBluetoothTaskRunner(base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT,
InitializeWithBluetoothTaskRunner(base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN}));
}

@ -26,6 +26,7 @@
#include "base/stl_util.h"
#include "base/strings/string_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/time/time.h"
#include "device/bluetooth/bluez/bluetooth_service_attribute_value_bluez.h"
@ -533,10 +534,10 @@ void FakeBluetoothDeviceClient::ConnectProfile(
return;
}
base::PostTask(FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&SimulatedProfileSocket, fds[0]));
base::ThreadPool::PostTask(
FROM_HERE,
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&SimulatedProfileSocket, fds[0]));
base::ScopedFD fd(fds[1]);

@ -17,6 +17,7 @@
#include "base/strings/string16.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "device/fido/authenticator_supported_options.h"
#include "device/fido/ctap_get_assertion_request.h"
#include "device/fido/ctap_make_credential_request.h"
@ -65,9 +66,8 @@ void WinWebAuthnApiAuthenticator::MakeCredential(
}
is_pending_ = true;
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::TaskPriority::USER_BLOCKING, base::MayBlock()},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::TaskPriority::USER_BLOCKING, base::MayBlock()},
base::BindOnce(&AuthenticatorMakeCredentialBlocking, win_api_,
current_window_, cancellation_id_, std::move(request)),
base::BindOnce(&WinWebAuthnApiAuthenticator::MakeCredentialDone,
@ -108,9 +108,8 @@ void WinWebAuthnApiAuthenticator::GetAssertion(CtapGetAssertionRequest request,
is_pending_ = true;
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::TaskPriority::USER_BLOCKING, base::MayBlock()},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::TaskPriority::USER_BLOCKING, base::MayBlock()},
base::BindOnce(&AuthenticatorGetAssertionBlocking, win_api_,
current_window_, cancellation_id_, std::move(request)),
base::BindOnce(&WinWebAuthnApiAuthenticator::GetAssertionDone,

@ -9,6 +9,7 @@
#include "base/bind.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "extensions/browser/component_extension_resource_manager.h"
#include "extensions/browser/extension_api_frame_id_map.h"
@ -247,10 +248,9 @@ bool ExecuteCodeFunction::LoadFile(const std::string& file,
ui::ResourceBundle::GetSharedInstance().LoadDataResourceString(
resource_id));
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
base::BindOnce(
&ExecuteCodeFunction::LocalizeComponentResourceInBackground, this,
std::move(data), extension_id, extension_path,

@ -13,6 +13,7 @@
#include "base/memory/scoped_refptr.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "build/build_config.h"
#include "components/services/app_service/public/cpp/file_handler_info.h"
#include "content/public/browser/browser_context.h"
@ -175,10 +176,8 @@ void WritableFileChecker::Check() {
continue;
}
#endif
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::TaskPriority::USER_BLOCKING,
base::MayBlock()},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::TaskPriority::USER_BLOCKING, base::MayBlock()},
base::BindOnce(&PrepareNativeLocalFileForWritableApp, path,
is_directory),
base::BindOnce(&WritableFileChecker::OnPrepareFileDone, this, path));

@ -8,6 +8,7 @@
#include "base/files/file_path.h"
#include "base/files/file_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_task_runner_handle.h"
#include "content/public/browser/browser_context.h"
#include "net/base/filename_util.h"
@ -43,8 +44,8 @@ void EntryIsDirectory(content::BrowserContext* context,
}
#endif
base::PostTaskAndReplyWithResult(
FROM_HERE, {base::ThreadPool(), base::MayBlock()},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock()},
base::BindOnce(&GetIsDirectoryFromFileInfo, path), std::move(callback));
}

@ -8,6 +8,7 @@
#include "base/files/file_path.h"
#include "base/files/file_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_task_runner_handle.h"
#include "build/build_config.h"
#include "content/public/browser/browser_context.h"
@ -84,8 +85,8 @@ void OnGetMimeTypeFromMetadataForNonNativeLocalPathCompleted(
std::unique_ptr<std::string> mime_type_from_extension(new std::string);
std::string* const mime_type_from_extension_ptr =
mime_type_from_extension.get();
base::PostTaskAndReply(
FROM_HERE, {base::ThreadPool(), base::MayBlock()},
base::ThreadPool::PostTaskAndReply(
FROM_HERE, {base::MayBlock()},
base::BindOnce(base::IgnoreResult(&net::GetMimeTypeFromFile), local_path,
mime_type_from_extension_ptr),
base::BindOnce(&OnGetMimeTypeFromFileForNonNativeLocalPathCompleted,
@ -126,8 +127,8 @@ void OnGetMimeTypeFromFileForNativeLocalPathCompleted(
std::unique_ptr<std::string> sniffed_mime_type(
new std::string(kMimeTypeApplicationOctetStream));
std::string* const sniffed_mime_type_ptr = sniffed_mime_type.get();
base::PostTaskAndReply(
FROM_HERE, {base::ThreadPool(), base::MayBlock()},
base::ThreadPool::PostTaskAndReply(
FROM_HERE, {base::MayBlock()},
base::BindOnce(&SniffMimeType, local_path, sniffed_mime_type_ptr),
base::BindOnce(&OnSniffMimeTypeForNativeLocalPathCompleted,
std::move(sniffed_mime_type), std::move(callback)));
@ -158,8 +159,8 @@ void GetMimeTypeForLocalPath(
std::unique_ptr<std::string> mime_type_from_extension(new std::string);
std::string* const mime_type_from_extension_ptr =
mime_type_from_extension.get();
base::PostTaskAndReply(
FROM_HERE, {base::ThreadPool(), base::MayBlock()},
base::ThreadPool::PostTaskAndReply(
FROM_HERE, {base::MayBlock()},
base::BindOnce(base::IgnoreResult(&net::GetMimeTypeFromFile), local_path,
mime_type_from_extension_ptr),
base::BindOnce(&OnGetMimeTypeFromFileForNativeLocalPathCompleted,

@ -23,6 +23,7 @@
#include "base/strings/stringprintf.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/value_conversions.h"
#include "base/values.h"
#include "build/build_config.h"
@ -333,9 +334,8 @@ ExtensionFunction::ResponseAction FileSystemGetWritableEntryFunction::Run() {
return RespondNow(Error(error));
}
base::PostTaskAndReply(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTaskAndReply(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&FileSystemGetWritableEntryFunction::SetIsDirectoryAsync,
this),
base::BindOnce(
@ -519,9 +519,8 @@ void FileSystemChooseEntryFunction::FilesSelected(
browser_context(), paths[0]);
#endif
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(
&FileSystemChooseEntryFunction::ConfirmDirectoryAccessAsync, this,
non_native_path, paths, web_contents));
@ -768,9 +767,8 @@ ExtensionFunction::ResponseAction FileSystemChooseEntryFunction::Run() {
return RespondLater();
}
#endif
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&base::DirectoryExists, previous_path),
std::move(set_initial_path_callback));

@ -7,6 +7,7 @@
#include "base/bind.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/task_runner_util.h"
#include "content/public/browser/browser_thread.h"
@ -14,8 +15,8 @@ namespace extensions {
SystemInfoProvider::SystemInfoProvider()
: is_waiting_for_completion_(false),
task_runner_(base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
task_runner_(base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(),
/* default priority, */
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN})) {}

@ -11,6 +11,7 @@
#include "base/metrics/histogram_macros.h"
#include "base/stl_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/timer/elapsed_timer.h"
#include "content/public/browser/browser_thread.h"
#include "crypto/secure_hash.h"
@ -99,9 +100,8 @@ void ContentVerifyJob::DidGetContentHashOnIO(
if (test_observer)
test_observer->JobStarted(extension_id_, relative_path_);
// Build |hash_reader_|.
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::BindOnce(&ContentHashReader::Create, relative_path_, content_hash),
base::BindOnce(&ContentVerifyJob::OnHashesReady, this));
}

@ -34,6 +34,7 @@
#include "base/strings/stringprintf.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_restrictions.h"
#include "base/timer/elapsed_timer.h"
#include "build/build_config.h"
@ -559,8 +560,8 @@ class ExtensionURLLoaderFactory : public network::mojom::URLLoaderFactory {
scoped_refptr<ContentVerifier> content_verifier =
extension_info_map_->content_verifier();
base::PostTaskAndReply(
FROM_HERE, {base::ThreadPool(), base::MayBlock()},
base::ThreadPool::PostTaskAndReply(
FROM_HERE, {base::MayBlock()},
base::BindOnce(&ReadResourceFilePathAndLastModifiedTime, resource,
directory_path, base::Unretained(read_file_path),
base::Unretained(last_modified_time)),

@ -16,6 +16,7 @@
#include "base/files/file_util.h"
#include "base/strings/string_number_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "content/public/browser/browser_thread.h"
#include "extensions/browser/component_extension_resource_manager.h"
#include "extensions/browser/extensions_browser_client.h"
@ -263,9 +264,8 @@ void ImageLoader::LoadImagesAsync(
const std::vector<ImageRepresentation>& info_list,
ImageLoaderImageCallback callback) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::BindOnce(LoadImagesBlocking, info_list,
LoadResourceBitmaps(extension, info_list)),
base::BindOnce(&ImageLoader::ReplyBack, weak_ptr_factory_.GetWeakPtr(),
@ -277,9 +277,8 @@ void ImageLoader::LoadImageFamilyAsync(
const std::vector<ImageRepresentation>& info_list,
ImageLoaderImageFamilyCallback callback) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::BindOnce(LoadImagesBlocking, info_list,
LoadResourceBitmaps(extension, info_list)),
base::BindOnce(&ImageLoader::ReplyBackWithImageFamily,

@ -13,6 +13,7 @@
#include "base/optional.h"
#include "base/strings/string_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "components/crx_file/crx_verifier.h"
#include "components/update_client/utils.h"
#include "content/public/browser/browser_task_traits.h"
@ -148,9 +149,8 @@ void UpdateDataProvider::RunInstallCallback(
<< public_key;
if (!browser_context_) {
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::TaskPriority::BEST_EFFORT, base::MayBlock()},
base::ThreadPool::PostTask(
FROM_HERE, {base::TaskPriority::BEST_EFFORT, base::MayBlock()},
base::BindOnce(base::IgnoreResult(&base::DeleteFile), unpacked_dir,
true));
return;

@ -13,6 +13,7 @@
#include "base/sequenced_task_runner.h"
#include "base/strings/string_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "content/public/browser/browser_context.h"
#include "extensions/browser/guest_view/web_view/web_ui/web_ui_url_fetcher.h"
@ -154,9 +155,9 @@ void WebUIUserScriptLoader::OnSingleWebUIURLFetchComplete(
}
void WebUIUserScriptLoader::OnWebUIURLFetchComplete() {
base::PostTask(FROM_HERE, {base::ThreadPool(), base::MayBlock()},
base::BindOnce(&SerializeOnBlockingTask,
base::SequencedTaskRunnerHandle::Get(),
std::move(user_scripts_cache_),
std::move(scripts_loaded_callback_)));
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock()},
base::BindOnce(
&SerializeOnBlockingTask, base::SequencedTaskRunnerHandle::Get(),
std::move(user_scripts_cache_), std::move(scripts_loaded_callback_)));
}

@ -23,6 +23,7 @@
#include "base/strings/string_number_conversions.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/task_runner_util.h"
#include "build/branding_buildflags.h"
#include "build/build_config.h"
@ -228,8 +229,8 @@ HeadlessShell::~HeadlessShell() = default;
void HeadlessShell::OnStart(HeadlessBrowser* browser) {
browser_ = browser;
devtools_client_ = HeadlessDevToolsClient::Create();
file_task_runner_ = base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT});
file_task_runner_ = base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT});
HeadlessBrowserContext::Builder context_builder =
browser_->CreateBrowserContextBuilder();

@ -11,6 +11,7 @@
#include "base/metrics/user_metrics_action.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "build/branding_buildflags.h"
#include "components/crash/core/common/crash_keys.h"
#include "components/metrics/metrics_pref_names.h"
@ -282,9 +283,8 @@ using metrics_mediator::kAppEnteredBackgroundDateKey;
}
app_group::main_app::RecordWidgetUsage();
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&app_group::main_app::ProcessPendingLogs, callback));
}

@ -16,6 +16,7 @@
#include "base/strings/sys_string_conversions.h"
#include "base/system/sys_info.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#import "ios/chrome/browser/crash_report/breakpad_helper.h"
#import "ios/chrome/browser/metrics/previous_session_info.h"
@ -57,17 +58,15 @@ void UpdateMemoryValues() {
// |kMemoryMonitorDelayInSeconds|.
void AsynchronousFreeMemoryMonitor() {
UpdateMemoryValues();
base::PostDelayedTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostDelayedTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&AsynchronousFreeMemoryMonitor),
base::TimeDelta::FromSeconds(kMemoryMonitorDelayInSeconds));
}
} // namespace
void StartFreeMemoryMonitor() {
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&AsynchronousFreeMemoryMonitor));
}

@ -17,6 +17,7 @@
#include "base/path_service.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/time/default_clock.h"
#include "base/time/default_tick_clock.h"
#include "components/component_updater/component_updater_service.h"
@ -444,9 +445,8 @@ void ApplicationContextImpl::CreateGCMDriver() {
CHECK(base::PathService::Get(ios::DIR_GLOBAL_GCM_STORE, &store_path));
scoped_refptr<base::SequencedTaskRunner> blocking_task_runner(
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN}));
gcm_driver_ = gcm::CreateGCMDriverDesktop(

@ -14,6 +14,7 @@
#include "base/logging.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "components/cookie_config/cookie_store_util.h"
#include "components/net_log/chrome_net_log.h"
#include "components/prefs/json_pref_store.h"
@ -161,9 +162,8 @@ void ChromeBrowserStateImplIOData::InitializeInternal(
profile_path_.Append(kIOSChromeNetworkPersistentStateFilename));
network_json_store_ = new JsonPrefStore(
network_json_store_filepath, std::unique_ptr<PrefFilter>(),
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::BLOCK_SHUTDOWN}));
network_json_store_->ReadPrefsAsync(nullptr);

@ -23,6 +23,7 @@
#include "base/strings/string_number_conversions.h"
#include "base/strings/string_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_task_runner_handle.h"
#include "components/content_settings/core/browser/content_settings_provider.h"
#include "components/content_settings/core/browser/cookie_settings.h"
@ -308,9 +309,8 @@ void ChromeBrowserStateIOData::Init(
transport_security_persister_ =
std::make_unique<net::TransportSecurityPersister>(
transport_security_state_.get(), profile_params_->path,
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::BLOCK_SHUTDOWN}));
}

@ -15,6 +15,7 @@
#include "base/sequenced_task_runner.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "components/password_manager/core/browser/password_store.h"
#include "components/prefs/pref_service.h"
@ -136,9 +137,8 @@ ChromeBrowserState* ChromeBrowserStateManagerImpl::GetBrowserState(
// this profile are executed in expected order (what was previously assured by
// the FILE thread).
scoped_refptr<base::SequencedTaskRunner> io_task_runner =
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::TaskShutdownBehavior::BLOCK_SHUTDOWN,
base::MayBlock()});
base::ThreadPool::CreateSequencedTaskRunner(
{base::TaskShutdownBehavior::BLOCK_SHUTDOWN, base::MayBlock()});
std::unique_ptr<ChromeBrowserStateImpl> browser_state_impl(
new ChromeBrowserStateImpl(io_task_runner, path));
@ -190,9 +190,9 @@ void ChromeBrowserStateManagerImpl::DoFinalInit(
// Log the browser state size after a reasonable startup delay.
base::FilePath path =
browser_state->GetOriginalChromeBrowserState()->GetStatePath();
base::PostDelayedTask(
base::ThreadPool::PostDelayedTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT,
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&BrowserStateSizeTask, path),
base::TimeDelta::FromSeconds(112));

@ -13,6 +13,7 @@
#include "base/mac/foundation_util.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "components/prefs/pref_service.h"
#include "google_apis/gaia/gaia_auth_util.h"
#include "ios/chrome/browser/application_context.h"
@ -143,9 +144,8 @@ void ChromeBrowserStateRemovalController::RemoveBrowserStatesIfNecessary() {
if (is_removing_browser_states) {
SetHasBrowserStateBeenRemoved(true);
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&NukeBrowserStates, browser_states_to_nuke));
}
}

@ -16,6 +16,7 @@
#include "base/run_loop.h"
#include "base/single_thread_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_task_runner_handle.h"
#include "components/bookmarks/browser/bookmark_model.h"
#include "components/bookmarks/common/bookmark_constants.h"
@ -135,9 +136,8 @@ TestChromeBrowserState::TestChromeBrowserState(
std::unique_ptr<sync_preferences::PrefServiceSyncable> prefs,
TestingFactories testing_factories,
RefcountedTestingFactories refcounted_testing_factories)
: ChromeBrowserState(base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::BLOCK_SHUTDOWN})),
: ChromeBrowserState(base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskShutdownBehavior::BLOCK_SHUTDOWN})),
state_path_(path),
prefs_(std::move(prefs)),
testing_prefs_(nullptr),

@ -19,6 +19,7 @@
#include "base/path_service.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "ios/chrome/browser/chrome_paths.h"
#import "ios/chrome/browser/crash_report/crash_report_user_application_state.h"
#import "ios/chrome/browser/crash_report/main_thread_freeze_detector.h"
@ -204,9 +205,8 @@ bool UserEnabledUploading() {
void CleanupCrashReports() {
base::FilePath crash_directory;
base::PathService::Get(ios::DIR_CRASH_DUMPS, &crash_directory);
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&DeleteAllReportsInDirectory, crash_directory));
}

@ -14,6 +14,7 @@
#include "base/strings/sys_string_conversions.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#import "ios/chrome/browser/download/ar_quick_look_tab_helper_delegate.h"
#include "ios/chrome/browser/download/download_directory_util.h"
#include "ios/chrome/browser/download/usdz_mime_type.h"
@ -110,9 +111,8 @@ void ARQuickLookTabHelper::Download(
// Take ownership of |download_task| and start the download.
download_task_ = std::move(download_task);
download_task_->AddObserver(this);
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::BindOnce(&base::CreateDirectory, download_dir),
base::BindOnce(&ARQuickLookTabHelper::DownloadWithDestinationDir,
AsWeakPtr(), download_dir, download_task_.get()));
@ -155,8 +155,8 @@ void ARQuickLookTabHelper::DownloadWithDestinationDir(
return;
}
auto task_runner = base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_VISIBLE});
auto task_runner = base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_VISIBLE});
base::string16 file_name = download_task_->GetSuggestedFilename();
base::FilePath path = destination_dir.Append(base::UTF16ToUTF8(file_name));
auto writer = std::make_unique<net::URLFetcherFileWriter>(task_runner, path);

@ -11,6 +11,7 @@
#include "base/mac/foundation_util.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "ios/web/common/features.h"
#if !defined(__has_feature) || !__has_feature(objc_arc)
@ -47,8 +48,7 @@ bool GetDownloadsDirectory(base::FilePath* directory_path) {
void DeleteDownloadsDirectory() {
// If downloads manager's flag is enabled, keeps downloads folder.
if (!base::FeatureList::IsEnabled(web::features::kEnablePersistentDownloads))
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&DeleteDownloadsDirectorySync));
}

@ -9,6 +9,7 @@
#include "base/logging.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "components/bookmarks/browser/bookmark_model.h"
#include "components/bookmarks/browser/url_and_title.h"
@ -221,9 +222,8 @@ void ExternalFileRemoverImpl::RemoveFiles(
const NSInteger kMinimumAgeInDays = 30;
NSInteger age_in_days = all_files ? 0 : kMinimumAgeInDays;
base::PostTaskAndReply(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTaskAndReply(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&RemoveFilesWithOptions, referenced_files, age_in_days),
base::Bind(&RunCallback, base::Passed(&closure_runner)));
}

@ -8,6 +8,7 @@
#include "base/memory/ref_counted.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "components/feature_engagement/public/tracker.h"
#include "ios/chrome/browser/browser_state/chrome_browser_state.h"
#include "ios/chrome/browser/chrome_constants.h"
@ -32,8 +33,8 @@ std::unique_ptr<KeyedService> CreateFeatureEngagementTracker(
ChromeBrowserState::FromBrowserState(context);
scoped_refptr<base::SequencedTaskRunner> background_task_runner =
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT});
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT});
base::FilePath storage_dir = browser_state->GetStatePath().Append(
kIOSFeatureEngagementTrackerStorageDirname);

@ -10,6 +10,7 @@
#include "base/no_destructor.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "build/branding_buildflags.h"
#include "components/gcm_driver/gcm_client_factory.h"
#include "components/gcm_driver/gcm_profile_service.h"
@ -94,9 +95,8 @@ IOSChromeGCMProfileServiceFactory::BuildServiceInstanceFor(
DCHECK(!context->IsOffTheRecord());
scoped_refptr<base::SequencedTaskRunner> blocking_task_runner(
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN}));
ChromeBrowserState* browser_state =
ChromeBrowserState::FromBrowserState(context);

@ -13,6 +13,7 @@
#include "base/path_service.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/time/default_tick_clock.h"
#include "components/content_settings/core/browser/cookie_settings.h"
#include "components/content_settings/core/common/content_settings_pattern.h"
@ -100,9 +101,8 @@ void IOSChromeMainParts::PreCreateThreads() {
// remaining BACKGROUND+BLOCK_SHUTDOWN tasks is bumped by the ThreadPool on
// shutdown.
scoped_refptr<base::SequencedTaskRunner> local_state_task_runner =
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::BLOCK_SHUTDOWN});
base::FilePath local_state_path;

@ -8,6 +8,7 @@
#include "base/json/json_reader.h"
#include "base/strings/stringprintf.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/values.h"
@ -41,9 +42,8 @@ void ParseJsonOnBackgroundThread(
void InProcessJsonParser::Parse(const std::string& unsafe_json,
SuccessCallback success_callback,
ErrorCallback error_callback) {
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&ParseJsonOnBackgroundThread,
base::ThreadTaskRunnerHandle::Get(), unsafe_json,
std::move(success_callback), std::move(error_callback)));

@ -23,6 +23,7 @@
#include "base/rand_util.h"
#include "base/strings/string16.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/platform_thread.h"
#include "components/crash/core/common/crash_keys.h"
#include "components/history/core/browser/history_service.h"
@ -112,13 +113,13 @@ std::unique_ptr<metrics::FileMetricsProvider> CreateFileMetricsProvider(
} else {
// When metrics reporting is not enabled, any existing files should be
// deleted in order to preserve user privacy.
base::PostTask(FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
base::BindOnce(base::IgnoreResult(&base::DeleteFile),
std::move(browser_metrics_upload_dir),
/*recursive=*/true));
base::ThreadPool::PostTask(
FROM_HERE,
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
base::BindOnce(base::IgnoreResult(&base::DeleteFile),
std::move(browser_metrics_upload_dir),
/*recursive=*/true));
}
}
return file_metrics_provider;

@ -14,6 +14,7 @@
#include "base/logging.h"
#include "base/memory/ref_counted.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "ios/chrome/browser/browser_state/chrome_browser_state.h"
#import "ios/net/cookies/cookie_store_ios.h"
#import "ios/net/cookies/system_cookie_store.h"
@ -46,8 +47,8 @@ scoped_refptr<net::SQLitePersistentCookieStore> CreatePersistentCookieStore(
return scoped_refptr<net::SQLitePersistentCookieStore>(
new net::SQLitePersistentCookieStore(
path, base::CreateSingleThreadTaskRunner({web::WebThread::IO}),
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT}),
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT}),
restore_old_session_cookies, crypto_delegate));
}

@ -12,6 +12,7 @@
#include "base/no_destructor.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "components/keyed_service/core/service_access_type.h"
#include "components/keyed_service/ios/browser_state_dependency_manager.h"
@ -90,8 +91,8 @@ IOSChromePasswordStoreFactory::BuildServiceInstanceFor(
// TODO(crbug.com/741660): Create the task runner inside password_manager
// component instead.
scoped_refptr<base::SequencedTaskRunner> db_task_runner(
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::USER_VISIBLE}));
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_VISIBLE}));
scoped_refptr<password_manager::PasswordStore> store =
new password_manager::PasswordStoreDefault(std::move(login_db));

@ -14,6 +14,7 @@
#include "base/strings/stringprintf.h"
#include "base/system/sys_info.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "components/policy/core/common/async_policy_provider.h"
#include "components/policy/core/common/cloud/device_management_service.h"
#include "components/policy/core/common/configuration_policy_provider.h"
@ -69,9 +70,9 @@ BrowserPolicyConnectorIOS::CreatePolicyProviders() {
std::unique_ptr<ConfigurationPolicyProvider>
BrowserPolicyConnectorIOS::CreatePlatformProvider() {
std::unique_ptr<AsyncPolicyLoader> loader(new PolicyLoaderIOS(
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT})));
std::unique_ptr<AsyncPolicyLoader> loader(
new PolicyLoaderIOS(base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT})));
return std::make_unique<AsyncPolicyProvider>(GetSchemaRegistry(),
std::move(loader));

@ -12,6 +12,7 @@
#include "base/strings/stringprintf.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/timer/timer.h"
#include "components/reading_list/core/offline_url_utils.h"
#include "components/reading_list/core/reading_list_entry.h"
@ -283,9 +284,9 @@ void OfflinePageTabHelper::PresentOfflinePageForOnlineUrl(const GURL& url) {
.DirName();
base::FilePath offline_path = entry->DistilledPath();
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_BLOCKING,
{base::MayBlock(), base::TaskPriority::USER_BLOCKING,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
base::BindOnce(&GetOfflineData, offline_root, offline_path),
base::BindOnce(&OfflinePageTabHelper::LoadData, base::Unretained(this),

@ -14,6 +14,7 @@
#include "base/metrics/histogram_macros.h"
#include "base/strings/string_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "components/reading_list/core/offline_url_utils.h"
#include "components/reading_list/core/reading_list_entry.h"
#include "components/reading_list/core/reading_list_model.h"
@ -169,9 +170,9 @@ void ReadingListDownloadService::SyncWithModel() {
break;
}
}
base::PostTaskAndReply(
base::ThreadPool::PostTaskAndReply(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_VISIBLE,
{base::MayBlock(), base::TaskPriority::USER_VISIBLE,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
base::Bind(&::CleanUpFiles, OfflineRoot(), processed_directories),
base::Bind(&ReadingListDownloadService::DownloadUnprocessedEntries,

@ -14,6 +14,7 @@
#include "base/path_service.h"
#include "base/stl_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "components/reading_list/core/offline_url_utils.h"
#include "ios/chrome/browser/chrome_paths.h"
#include "ios/chrome/browser/dom_distiller/distiller_viewer.h"
@ -59,9 +60,8 @@ URLDownloader::URLDownloader(
base_directory_(chrome_profile_path),
mime_type_(),
url_loader_factory_(std::move(url_loader_factory)),
task_runner_(base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
task_runner_(base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN})),
task_tracker_() {}

@ -18,6 +18,7 @@
#include "base/sequenced_task_runner.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "base/time/time.h"
#import "ios/chrome/browser/sessions/session_ios.h"
@ -86,9 +87,8 @@ NSString* const kRootObjectKey = @"root"; // Key for the root object.
- (instancetype)init {
scoped_refptr<base::SequencedTaskRunner> taskRunner =
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::BLOCK_SHUTDOWN});
return [self initWithTaskRunner:taskRunner];
}

@ -15,6 +15,7 @@
#include "base/strings/sys_string_conversions.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "components/bookmarks/browser/bookmark_model.h"
#include "components/reading_list/core/reading_list_model.h"
@ -132,9 +133,8 @@ void LogHistogramReceivedItem(ShareExtensionItemReceived type) {
if (self) {
_readingListModel = readingListModel;
_bookmarkModel = bookmarkModel;
_taskRunner =
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT});
_taskRunner = base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT});
[[NSNotificationCenter defaultCenter]
addObserver:self

@ -20,6 +20,7 @@
#include "base/stl_util.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/task_runner_util.h"
#include "base/threading/scoped_blocking_call.h"
#import "ios/chrome/browser/snapshots/snapshot_cache_observer.h"
@ -283,9 +284,8 @@ void ConvertAndSaveGreyImage(NSString* session_id,
_cacheDirectory = cacheDirectory;
_snapshotsScale = snapshotsScale;
_taskRunner =
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::USER_VISIBLE});
_taskRunner = base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_VISIBLE});
_observers = [SnapshotCacheObservers observers];
_markedIDs = [[NSMutableSet alloc] init];

@ -14,6 +14,7 @@
#include "base/stl_util.h"
#include "base/strings/stringprintf.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#if !defined(__has_feature) || !__has_feature(objc_arc)
#error "This file requires ARC support."
@ -40,9 +41,8 @@ void ClearIOSSnapshots(base::OnceClosure callback) {
// list of snapshots stored on the device can't be obtained programmatically.
std::vector<base::FilePath> snapshots_paths;
GetSnapshotsPaths(&snapshots_paths);
base::PostTaskAndReply(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTaskAndReply(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&DeleteAllFiles, std::move(snapshots_paths)),
std::move(callback));
}

@ -12,6 +12,7 @@
#include "base/strings/sys_string_conversions.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "ios/chrome/browser/download/download_directory_util.h"
#import "ios/chrome/browser/download/google_drive_app_util.h"
#include "ios/chrome/grit/ios_strings.h"
@ -58,9 +59,8 @@ void DownloadManagerMediator::StartDowloading() {
// "Start Download" button.
[consumer_ setState:kDownloadManagerStateInProgress];
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock(), base::TaskPriority::USER_VISIBLE},
base::BindOnce(&base::CreateDirectory, download_dir),
base::BindOnce(&DownloadManagerMediator::DownloadWithDestinationDir,
weak_ptr_factory_.GetWeakPtr(), download_dir, task_));
@ -80,8 +80,8 @@ void DownloadManagerMediator::DownloadWithDestinationDir(
return;
}
auto task_runner = base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT});
auto task_runner = base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT});
base::string16 file_name = task_->GetSuggestedFilename();
base::FilePath path = destination_dir.Append(base::UTF16ToUTF8(file_name));
auto writer = std::make_unique<net::URLFetcherFileWriter>(task_runner, path);

@ -10,6 +10,7 @@
#include "base/metrics/histogram_macros.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/time/time.h"
#include "components/signin/public/identity_manager/identity_manager.h"
#include "ios/chrome/browser/browser_state/chrome_browser_state.h"
@ -143,9 +144,8 @@ BOOL FixOrphanWord(UILabel* label) {
void WriteFirstRunSentinelAndRecordMetrics(ChromeBrowserState* browserState,
BOOL sign_in_attempted,
BOOL has_sso_account) {
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&CreateSentinel));
RecordFirstRunMetricsInternal(browserState, sign_in_attempted,
has_sso_account);

@ -11,6 +11,7 @@
#include "base/format_macros.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "components/image_fetcher/ios/ios_image_data_fetcher_wrapper.h"
#include "components/strings/grit/components_strings.h"
@ -124,9 +125,9 @@
- (void)saveImage:(NSData*)data
withFileExtension:(NSString*)fileExtension
completion:(void (^)(BOOL, NSError*))completion {
base::PostTask(
base::ThreadPool::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT,
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
base::BindOnce(^{
base::ScopedBlockingCall scoped_blocking_call(
@ -151,10 +152,9 @@
creationRequestForAssetFromImageAtFileURL:fileURL];
}
completionHandler:^(BOOL success, NSError* error) {
base::PostTask(
base::ThreadPool::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
base::BindOnce(^{
base::ScopedBlockingCall scoped_blocking_call(

@ -8,6 +8,7 @@
#include "base/hash/md5.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "components/favicon/core/fallback_url_util.h"
#include "components/ntp_tiles/ntp_tile.h"
@ -127,9 +128,8 @@ void SaveMostVisitedToDisk(const ntp_tiles::NTPTilesVector& most_visited_data,
}
UpdateTileList(most_visited_data);
base::PostTaskAndReply(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTaskAndReply(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(&ClearOutdatedIcons, most_visited_data,
favicons_directory),
base::BindOnce(
@ -208,10 +208,9 @@ void UpdateSingleFavicon(const GURL& site_url,
[imageData writeToURL:fileURL atomically:YES];
});
base::PostTask(FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT},
std::move(writeImage));
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
std::move(writeImage));
} else {
NSDictionary* tiles = ReadSavedMostVisited();
NTPTile* tile = [tiles objectForKey:siteNSURL];
@ -234,10 +233,9 @@ void UpdateSingleFavicon(const GURL& site_url,
[[NSFileManager defaultManager] removeItemAtURL:fileURL error:nil];
});
base::PostTask(FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT},
std::move(removeImage));
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
std::move(removeImage));
}
};

@ -13,6 +13,7 @@
#include "base/sequenced_task_runner.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "components/strings/grit/components_strings.h"
#import "ios/chrome/browser/ui/alert_coordinator/alert_coordinator.h"
@ -234,9 +235,8 @@ class OpenInControllerBridge
initWithTarget:self
action:@selector(handleTapFrom:)];
[_tapRecognizer setDelegate:self];
_sequencedTaskRunner =
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT});
_sequencedTaskRunner = base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT});
_isOpenInMenuDisplayed = NO;
_previousScrollViewOffset = 0;
}

@ -10,6 +10,7 @@
#include "base/metrics/histogram_macros.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/task_runner_util.h"
#include "base/threading/scoped_blocking_call.h"
#include "components/autofill/core/common/password_form.h"
@ -43,9 +44,8 @@ enum class ReauthenticationStatus {
- (void)serializePasswords:
(std::vector<std::unique_ptr<autofill::PasswordForm>>)passwords
handler:(void (^)(std::string))serializedPasswordsHandler {
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_BLOCKING},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock(), base::TaskPriority::USER_BLOCKING},
base::BindOnce(&password_manager::PasswordCSVWriter::SerializePasswords,
std::move(passwords)),
base::BindOnce(serializedPasswordsHandler));
@ -90,9 +90,8 @@ enum class ReauthenticationStatus {
}
return WriteToURLStatus::SUCCESS;
};
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_BLOCKING},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::MayBlock(), base::TaskPriority::USER_BLOCKING},
base::BindOnce(writeToFile), base::BindOnce(handler));
}
@ -326,9 +325,8 @@ enum class ReauthenticationStatus {
- (void)deleteTemporaryFile:(NSURL*)passwordsTempFileURL {
NSURL* uniqueDirectoryURL =
[passwordsTempFileURL URLByDeletingLastPathComponent];
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::ThreadPool::PostTask(
FROM_HERE, {base::MayBlock(), base::TaskPriority::BEST_EFFORT},
base::BindOnce(^{
NSFileManager* fileManager = [NSFileManager defaultManager];
base::ScopedBlockingCall scoped_blocking_call(

@ -12,6 +12,7 @@
#include "base/memory/ref_counted.h"
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "ios/web/public/browser_state.h"
#include "ios/web/public/security/certificate_policy_cache.h"
#include "ios/web/public/thread/web_task_traits.h"
@ -202,9 +203,8 @@ using web::WebThread;
DCHECK(completionHandler);
// SecTrustEvaluate performs trust evaluation synchronously, possibly making
// network requests. The UI thread should not be blocked by that operation.
base::PostTask(
FROM_HERE, {base::ThreadPool(), TaskShutdownBehavior::BLOCK_SHUTDOWN},
base::BindOnce(^{
base::ThreadPool::PostTask(
FROM_HERE, {TaskShutdownBehavior::BLOCK_SHUTDOWN}, base::BindOnce(^{
SecTrustResultType trustResult = kSecTrustResultInvalid;
if (SecTrustEvaluate(trust.get(), &trustResult) != errSecSuccess) {
trustResult = kSecTrustResultInvalid;

@ -13,6 +13,7 @@
#include "base/memory/ref_counted.h"
#include "base/path_service.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#import "ios/net/cookies/cookie_store_ios.h"
#include "ios/web/public/browsing_data/system_cookie_store_util.h"
#import "ios/web/public/web_client.h"
@ -97,9 +98,8 @@ net::URLRequestContext* ShellURLRequestContextGetter::GetURLRequestContext() {
transport_security_persister_ =
std::make_unique<net::TransportSecurityPersister>(
url_request_context_->transport_security_state(), base_path_,
base::CreateSequencedTaskRunner({base::ThreadPool(),
base::MayBlock(),
base::TaskPriority::BEST_EFFORT}));
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT}));
storage_->set_http_server_properties(
std::make_unique<net::HttpServerProperties>());

@ -9,6 +9,7 @@
#include "base/strings/sys_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#import "ios/web/public/download/download_task.h"
#include "ios/web/public/download/download_task_observer.h"
#include "ios/web_view/internal/cwv_web_view_internal.h"
@ -101,8 +102,8 @@ class DownloadTaskObserverBridge : public web::DownloadTaskObserver {
- (void)startDownloadToLocalFileAtPath:(NSString*)path {
scoped_refptr<base::SequencedTaskRunner> taskRunner =
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT});
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT});
__block auto writer = std::make_unique<net::URLFetcherFileWriter>(
taskRunner, base::FilePath(base::SysNSStringToUTF8(path)));

@ -12,6 +12,7 @@
#include "base/no_destructor.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "components/keyed_service/core/service_access_type.h"
#include "components/keyed_service/ios/browser_state_dependency_manager.h"
@ -91,8 +92,8 @@ WebViewPasswordStoreFactory::BuildServiceInstanceFor(
// the passwords obtained through tasks on the background runner influence
// what the user sees.
scoped_refptr<base::SequencedTaskRunner> db_task_runner(
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::USER_VISIBLE}));
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_VISIBLE}));
scoped_refptr<password_manager::PasswordStore> store =
new password_manager::PasswordStoreDefault(std::move(login_db));

@ -10,6 +10,7 @@
#include "base/no_destructor.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "components/gcm_driver/gcm_client_factory.h"
#include "components/gcm_driver/gcm_profile_service.h"
#include "components/keyed_service/ios/browser_state_dependency_manager.h"
@ -93,9 +94,8 @@ WebViewGCMProfileServiceFactory::BuildServiceInstanceFor(
DCHECK(!context->IsOffTheRecord());
scoped_refptr<base::SequencedTaskRunner> blocking_task_runner(
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN}));
WebViewBrowserState* browser_state =
WebViewBrowserState::FromBrowserState(context);

@ -12,6 +12,7 @@
#include "base/memory/ref_counted.h"
#include "base/path_service.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#import "ios/net/cookies/cookie_store_ios.h"
#include "ios/web/public/browsing_data/system_cookie_store_util.h"
#import "ios/web/public/web_client.h"
@ -106,9 +107,8 @@ net::URLRequestContext* WebViewURLRequestContextGetter::GetURLRequestContext() {
transport_security_persister_ =
std::make_unique<net::TransportSecurityPersister>(
url_request_context_->transport_security_state(), base_path_,
base::CreateSequencedTaskRunner({base::ThreadPool(),
base::MayBlock(),
base::TaskPriority::BEST_EFFORT}));
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT}));
storage_->set_http_server_properties(
std::make_unique<net::HttpServerProperties>());

@ -12,6 +12,7 @@
#include "base/bind.h"
#include "base/synchronization/waitable_event.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/threading/thread_restrictions.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
@ -45,7 +46,7 @@ NetworkServiceConfigTestUtil::NetworkServiceConfigTestUtil(
NetworkServiceConfigTestUtil::NetworkServiceConfigTestUtil(
NetworkContextGetter network_context_getter)
: net_runner_(base::CreateSingleThreadTaskRunner({base::ThreadPool()})),
: net_runner_(base::ThreadPool::CreateSingleThreadTaskRunner({})),
mojo_runner_(base::SequencedTaskRunnerHandle::Get()),
network_context_getter_(network_context_getter) {}

@ -15,6 +15,7 @@
#include "base/sequence_checker.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "media/base/audio_parameters.h"
#include "media/base/media_export.h"
@ -63,9 +64,8 @@ class MEDIA_EXPORT AudioDebugFileWriter {
// The task runner to do file output operations on.
const scoped_refptr<base::SequencedTaskRunner> file_task_runner_ =
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::BLOCK_SHUTDOWN});
AudioFileWriterUniquePtr file_writer_;

@ -13,6 +13,7 @@
#include "base/strings/string_number_conversions.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "build/build_config.h"
#include "media/audio/audio_debug_recording_manager.h"
#include "media/audio/audio_manager.h"
@ -58,9 +59,9 @@ void CreateWavFile(const base::FilePath& debug_recording_file_path,
return;
}
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT,
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
base::BindOnce(
[](const base::FilePath& file_name) {

@ -17,6 +17,7 @@
#include "base/single_thread_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_checker.h"
#include "base/time/tick_clock.h"
@ -47,7 +48,7 @@ AudioThreadHangMonitor::Ptr AudioThreadHangMonitor::Create(
scoped_refptr<base::SingleThreadTaskRunner> audio_thread_task_runner,
scoped_refptr<base::SequencedTaskRunner> monitor_task_runner) {
if (!monitor_task_runner)
monitor_task_runner = base::CreateSequencedTaskRunner({base::ThreadPool()});
monitor_task_runner = base::ThreadPool::CreateSequencedTaskRunner({});
auto monitor =
Ptr(new AudioThreadHangMonitor(hang_action, hang_deadline, clock,

@ -24,6 +24,7 @@
#include "base/single_thread_task_runner.h"
#include "base/strings/string_number_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/task_runner_util.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/trace_event/trace_event.h"
@ -236,9 +237,9 @@ void DestructionHelper(
// used because virtual memory overhead is not considered blocking I/O; and
// CONTINUE_ON_SHUTDOWN is used to allow process termination to not block on
// completing the task.
base::PostTask(
base::ThreadPool::PostTask(
FROM_HERE,
{base::ThreadPool(), base::TaskPriority::BEST_EFFORT,
{base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(
[](scoped_refptr<base::SingleThreadTaskRunner> main_task_runner,

@ -5,6 +5,7 @@
#include "media/capabilities/learning_helper.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "media/learning/common/feature_library.h"
#include "media/learning/common/learning_task.h"
@ -50,9 +51,9 @@ LearningHelper::LearningHelper(FeatureProviderFactoryCB feature_factory) {
// it's likely that the session will live on the main thread, and handle
// delegation of LearningTaskControllers to other threads. However, for now,
// do it here.
learning_session_ =
std::make_unique<LearningSessionImpl>(base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::TaskPriority::BEST_EFFORT,
learning_session_ = std::make_unique<LearningSessionImpl>(
base::ThreadPool::CreateSequencedTaskRunner(
{base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN}));
// Register a few learning tasks.

@ -16,6 +16,7 @@
#include "base/metrics/histogram_macros.h"
#include "base/sequence_checker.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/time/default_clock.h"
#include "components/leveldb_proto/public/proto_database_provider.h"
#include "media/base/media_switches.h"
@ -73,9 +74,8 @@ std::unique_ptr<VideoDecodeStatsDBImpl> VideoDecodeStatsDBImpl::Create(
auto proto_db = db_provider->GetDB<DecodeStatsProto>(
leveldb_proto::ProtoDbType::VIDEO_DECODE_STATS_DB, db_dir,
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::BEST_EFFORT,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN}));
return base::WrapUnique(new VideoDecodeStatsDBImpl(std::move(proto_db)));

@ -13,6 +13,7 @@
#include "base/sequence_checker.h"
#include "base/system/system_monitor.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "device/udev_linux/udev.h"
#include "device/udev_linux/udev_watcher.h"
@ -114,9 +115,8 @@ void DeviceMonitorLinux::BlockingTaskRunnerHelper::OnDevicesChanged(
}
DeviceMonitorLinux::DeviceMonitorLinux()
: blocking_task_runner_(base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::USER_VISIBLE,
: blocking_task_runner_(base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_VISIBLE,
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN})),
blocking_task_helper_(new BlockingTaskRunnerHelper,
base::OnTaskRunnerDeleter(blocking_task_runner_)) {

@ -21,6 +21,7 @@
#include "base/strings/string_util.h"
#include "base/sys_byteorder.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/task_runner_util.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/time/time.h"
@ -921,9 +922,8 @@ FFmpegDemuxer::FFmpegDemuxer(
// FFmpeg has no asynchronous API, so we use base::WaitableEvents inside
// the BlockingUrlProtocol to handle hops to the render thread for network
// reads and seeks.
blocking_task_runner_(
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::USER_BLOCKING})),
blocking_task_runner_(base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_BLOCKING})),
data_source_(data_source),
media_log_(media_log),
encrypted_media_init_data_cb_(encrypted_media_init_data_cb),

@ -9,6 +9,7 @@
#include "base/sequenced_task_runner.h"
#include "base/synchronization/atomic_flag.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "media/base/bind_to_current_loop.h"
#include "media/base/decoder_buffer.h"
#include "media/base/video_frame.h"
@ -137,8 +138,8 @@ void OffloadingVideoDecoder::Initialize(const VideoDecoderConfig& config,
}
if (!offload_task_runner_) {
offload_task_runner_ = base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::TaskPriority::USER_BLOCKING});
offload_task_runner_ = base::ThreadPool::CreateSequencedTaskRunner(
{base::TaskPriority::USER_BLOCKING});
}
offload_task_runner_->PostTask(

@ -13,6 +13,7 @@
#include "base/logging.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/task_runner_util.h"
#include "base/threading/scoped_blocking_call.h"
#include "base/time/default_tick_clock.h"
@ -45,8 +46,8 @@ void ReleaseMediaCodecInternal(std::unique_ptr<MediaCodecBridge> codec) {
}
scoped_refptr<base::SequencedTaskRunner> CreateCodecTaskRunner() {
return base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::TaskPriority::USER_VISIBLE, base::MayBlock(),
return base::ThreadPool::CreateSequencedTaskRunner(
{base::TaskPriority::USER_VISIBLE, base::MayBlock(),
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN});
}

@ -12,6 +12,7 @@
#include "base/bind_helpers.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "media/base/video_types.h"
#include "media/gpu/macros.h"
@ -71,7 +72,7 @@ std::unique_ptr<ImageProcessor> ImageProcessor::Create(
ErrorCB error_cb,
scoped_refptr<base::SequencedTaskRunner> client_task_runner) {
scoped_refptr<base::SequencedTaskRunner> backend_task_runner =
base::CreateSequencedTaskRunner({base::ThreadPool()});
base::ThreadPool::CreateSequencedTaskRunner({});
auto wrapped_error_cb = base::BindRepeating(
base::IgnoreResult(&base::SequencedTaskRunner::PostTask),
client_task_runner, FROM_HERE, std::move(error_cb));

@ -12,6 +12,7 @@
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "build/build_config.h"
#include "media/base/limits.h"
#include "media/gpu/chromeos/dmabuf_video_frame_pool.h"
@ -92,9 +93,8 @@ VideoDecoderPipeline::VideoDecoderPipeline(
gpu::GpuMemoryBufferFactory* const gpu_memory_buffer_factory,
GetCreateVDFunctionsCB get_create_vd_functions_cb)
: client_task_runner_(std::move(client_task_runner)),
decoder_task_runner_(base::CreateSingleThreadTaskRunner(
{base::ThreadPool(), base::WithBaseSyncPrimitives(),
base::TaskPriority::USER_VISIBLE},
decoder_task_runner_(base::ThreadPool::CreateSingleThreadTaskRunner(
{base::WithBaseSyncPrimitives(), base::TaskPriority::USER_VISIBLE},
base::SingleThreadTaskRunnerThreadMode::DEDICATED)),
main_frame_pool_(std::move(frame_pool)),
gpu_memory_buffer_factory_(gpu_memory_buffer_factory),

@ -22,6 +22,7 @@
#include "base/numerics/safe_conversions.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "media/base/color_plane_layout.h"
#include "media/base/scopedfd_helper.h"
#include "media/gpu/chromeos/fourcc.h"
@ -124,8 +125,8 @@ V4L2ImageProcessorBackend::V4L2ImageProcessorBackend(
num_buffers_(num_buffers),
// We poll V4L2 device on this task runner, which blocks the task runner.
// Therefore we use dedicated SingleThreadTaskRunner here.
poll_task_runner_(base::CreateSingleThreadTaskRunner(
{base::ThreadPool()},
poll_task_runner_(base::ThreadPool::CreateSingleThreadTaskRunner(
{},
base::SingleThreadTaskRunnerThreadMode::DEDICATED)) {
DVLOGF(2);
DETACH_FROM_SEQUENCE(poll_sequence_checker_);

@ -26,6 +26,7 @@
#include "base/stl_util.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/trace_event/trace_event.h"
#include "gpu/ipc/service/gpu_memory_buffer_factory.h"
@ -167,8 +168,8 @@ V4L2VideoEncodeAccelerator::V4L2VideoEncodeAccelerator(
// performance is affected.
// TODO(akahuang): Remove WithBaseSyncPrimitives() after replacing poll
// thread by V4L2DevicePoller.
encoder_task_runner_(base::CreateSingleThreadTaskRunner(
{base::ThreadPool(), base::WithBaseSyncPrimitives()},
encoder_task_runner_(base::ThreadPool::CreateSingleThreadTaskRunner(
{base::WithBaseSyncPrimitives()},
base::SingleThreadTaskRunnerThreadMode::DEDICATED)) {
DCHECK_CALLED_ON_VALID_SEQUENCE(child_sequence_checker_);
DETACH_FROM_SEQUENCE(encoder_sequence_checker_);

@ -4,6 +4,7 @@
#include "media/gpu/vaapi/vaapi_image_decode_accelerator_worker.h"
#include "base/task/thread_pool.h"
#include "string.h"
#include <utility>
@ -150,7 +151,7 @@ VaapiImageDecodeAcceleratorWorker::Create() {
VaapiImageDecodeAcceleratorWorker::VaapiImageDecodeAcceleratorWorker(
VaapiImageDecoderVector decoders) {
DETACH_FROM_SEQUENCE(io_sequence_checker_);
decoder_task_runner_ = base::CreateSequencedTaskRunner({base::ThreadPool()});
decoder_task_runner_ = base::ThreadPool::CreateSequencedTaskRunner({});
DCHECK(decoder_task_runner_);
DCHECK(!decoders.empty());

@ -18,6 +18,7 @@
#include "base/numerics/safe_conversions.h"
#include "base/sequence_checker.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/trace_event/trace_event.h"
#include "gpu/ipc/common/gpu_memory_buffer_support.h"
@ -462,9 +463,8 @@ VaapiJpegEncodeAccelerator::Initialize(
return PLATFORM_FAILURE;
}
encoder_task_runner_ =
base::CreateSingleThreadTaskRunner({base::ThreadPool(), base::MayBlock(),
base::TaskPriority::USER_BLOCKING});
encoder_task_runner_ = base::ThreadPool::CreateSingleThreadTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_BLOCKING});
if (!encoder_task_runner_) {
VLOGF(1) << "Failed to create encoder task runner.";
return THREAD_CREATION_FAILED;

@ -25,6 +25,7 @@
#include "base/stl_util.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/trace_event/trace_event.h"
#include "build/build_config.h"
@ -249,8 +250,8 @@ VaapiVideoEncodeAccelerator::VaapiVideoEncodeAccelerator()
child_task_runner_(base::ThreadTaskRunnerHandle::Get()),
// TODO(akahuang): Change to use SequencedTaskRunner to see if the
// performance is affected.
encoder_task_runner_(base::CreateSingleThreadTaskRunner(
{base::ThreadPool(), base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
encoder_task_runner_(base::ThreadPool::CreateSingleThreadTaskRunner(
{base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN},
base::SingleThreadTaskRunnerThreadMode::DEDICATED)) {
VLOGF(2);
DCHECK_CALLED_ON_VALID_SEQUENCE(child_sequence_checker_);

@ -18,6 +18,7 @@
#include "base/strings/string_number_conversions.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "media/base/limits.h"
#include "media/webrtc/helpers.h"
#include "media/webrtc/webrtc_switches.h"
@ -145,9 +146,8 @@ void AudioProcessor::StartEchoCancellationDump(base::File file) {
if (!audio_processing_) {
// The destructor of File is blocking. Post it to a task runner to avoid
// blocking the main thread.
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::TaskPriority::LOWEST, base::MayBlock()},
base::ThreadPool::PostTask(
FROM_HERE, {base::TaskPriority::LOWEST, base::MayBlock()},
base::BindOnce([](base::File) {}, std::move(file)));
return;
}

@ -14,6 +14,7 @@
#include "base/rand_util.h"
#include "base/strings/string_number_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "mojo/public/cpp/bindings/message.h"
namespace {
@ -76,9 +77,8 @@ bool MessageDumper::Accept(mojo::Message* message) {
message->interface_name(), message->method_name());
static base::NoDestructor<scoped_refptr<base::TaskRunner>> task_runner(
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::USER_BLOCKING,
base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_BLOCKING,
base::TaskShutdownBehavior::SKIP_ON_SHUTDOWN}));
(*task_runner)

@ -14,6 +14,7 @@
#include "base/synchronization/lock.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/time/time.h"
#include "mojo/public/cpp/bindings/lib/binding_state.h"
#include "mojo/public/cpp/bindings/lib/test_random_mojo_delays.h"
@ -38,8 +39,7 @@ constexpr base::TimeDelta kPauseBindingsFrequency =
class RandomMojoDelays {
public:
RandomMojoDelays()
: runner_for_pauses_(
base::CreateSequencedTaskRunner({base::ThreadPool()})) {
: runner_for_pauses_(base::ThreadPool::CreateSequencedTaskRunner({})) {
DETACH_FROM_SEQUENCE(runner_for_pauses_sequence_checker);
}

@ -14,6 +14,7 @@
#include "base/run_loop.h"
#include "base/synchronization/waitable_event.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/test/bind_test_util.h"
#include "base/test/task_environment.h"
#include "base/threading/sequenced_task_runner_handle.h"
@ -210,7 +211,7 @@ TEST_F(AssociatedInterfaceTest, InterfacesAtBothEnds) {
class TestSender {
public:
TestSender()
: task_runner_(base::CreateSequencedTaskRunner({base::ThreadPool()})),
: task_runner_(base::ThreadPool::CreateSequencedTaskRunner({})),
next_sender_(nullptr),
max_value_to_send_(-1) {}
@ -257,7 +258,7 @@ class TestSender {
class TestReceiver {
public:
TestReceiver()
: task_runner_(base::CreateSequencedTaskRunner({base::ThreadPool()})),
: task_runner_(base::ThreadPool::CreateSequencedTaskRunner({})),
expected_calls_(0) {}
void SetUp(PendingAssociatedReceiver<IntegerSender> receiver0,
@ -957,8 +958,7 @@ TEST_F(AssociatedInterfaceTest, SharedAssociatedRemote) {
// Test the thread safe pointer can be used from another thread.
base::RunLoop run_loop;
auto sender_task_runner =
base::CreateSequencedTaskRunner({base::ThreadPool()});
auto sender_task_runner = base::ThreadPool::CreateSequencedTaskRunner({});
auto quit_closure = run_loop.QuitClosure();
sender_task_runner->PostTask(
FROM_HERE, base::BindLambdaForTesting([&] {
@ -982,7 +982,7 @@ struct ForwarderTestContext {
TEST_F(AssociatedInterfaceTest, SharedAssociatedRemoteWithTaskRunner) {
const scoped_refptr<base::SequencedTaskRunner> other_thread_task_runner =
base::CreateSequencedTaskRunner({base::ThreadPool()});
base::ThreadPool::CreateSequencedTaskRunner({});
ForwarderTestContext* context = new ForwarderTestContext();
PendingAssociatedRemote<IntegerSender> pending_remote;

@ -7,6 +7,7 @@
#include "base/bind.h"
#include "base/run_loop.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/test/bind_test_util.h"
#include "base/test/task_environment.h"
#include "base/threading/sequenced_task_runner_handle.h"
@ -117,7 +118,7 @@ TEST_F(BinderMapTest, CorrectSequence) {
GenericPendingReceiver receiver2(remote2.BindNewPipeAndPassReceiver());
auto task_runner1 = base::SequencedTaskRunnerHandle::Get();
auto task_runner2 = base::CreateSequencedTaskRunner({base::ThreadPool()});
auto task_runner2 = base::ThreadPool::CreateSequencedTaskRunner({});
TestInterface1Impl impl1;
std::unique_ptr<TestInterface2Impl> impl2;

@ -14,6 +14,7 @@
#include "base/optional.h"
#include "base/synchronization/lock.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/test/bind_test_util.h"
#include "mojo/public/cpp/bindings/async_flusher.h"
#include "mojo/public/cpp/bindings/pending_flush.h"
@ -40,7 +41,7 @@ class KeyValueStoreImpl : public base::RefCountedThreadSafe<KeyValueStoreImpl>,
public mojom::KeyValueStore {
public:
KeyValueStoreImpl()
: task_runner_(base::CreateSequencedTaskRunner({base::ThreadPool()})) {}
: task_runner_(base::ThreadPool::CreateSequencedTaskRunner({})) {}
void Bind(PendingReceiver<mojom::KeyValueStore> receiver) {
task_runner_->PostTask(
@ -65,7 +66,7 @@ class KeyValueStoreImpl : public base::RefCountedThreadSafe<KeyValueStoreImpl>,
class WriterImpl : public mojom::Writer {
public:
WriterImpl(KeyValueStoreImpl* key_value_store)
: task_runner_(base::CreateSequencedTaskRunner({base::ThreadPool()})),
: task_runner_(base::ThreadPool::CreateSequencedTaskRunner({})),
key_value_store_(key_value_store) {}
~WriterImpl() override = default;

@ -14,6 +14,7 @@
#include "base/run_loop.h"
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/test/bind_test_util.h"
#include "base/test/task_environment.h"
#include "base/threading/sequenced_task_runner_handle.h"
@ -261,7 +262,7 @@ TEST_P(EndToEndRemoteTest, EndToEnd) {
}
TEST_P(EndToEndRemoteTest, EndToEndOnSequence) {
RunTest(base::CreateSequencedTaskRunner({base::ThreadPool()}));
RunTest(base::ThreadPool::CreateSequencedTaskRunner({}));
}
TEST_P(RemoteTest, Movable) {
@ -880,8 +881,7 @@ TEST_P(RemoteTest, SharedRemote) {
// Send a message on |thread_safe_remote| from a different sequence.
auto main_task_runner = base::SequencedTaskRunnerHandle::Get();
auto sender_task_runner =
base::CreateSequencedTaskRunner({base::ThreadPool()});
auto sender_task_runner = base::ThreadPool::CreateSequencedTaskRunner({});
sender_task_runner->PostTask(
FROM_HERE, base::BindLambdaForTesting([&] {
shared_remote->Add(
@ -898,7 +898,7 @@ TEST_P(RemoteTest, SharedRemote) {
TEST_P(RemoteTest, SharedRemoteWithTaskRunner) {
const scoped_refptr<base::SequencedTaskRunner> other_thread_task_runner =
base::CreateSequencedTaskRunner({base::ThreadPool()});
base::ThreadPool::CreateSequencedTaskRunner({});
PendingRemote<math::Calculator> remote;
auto receiver = remote.InitWithNewPipeAndPassReceiver();
@ -942,7 +942,7 @@ TEST_P(RemoteTest, SharedRemoteDisconnectCallback) {
MathCalculatorImpl calc_impl(remote.InitWithNewPipeAndPassReceiver());
const scoped_refptr<base::SequencedTaskRunner> main_task_runner =
base::CreateSequencedTaskRunner({base::ThreadPool()});
base::ThreadPool::CreateSequencedTaskRunner({});
SharedRemote<math::Calculator> shared_remote(std::move(remote),
main_task_runner);
@ -994,8 +994,8 @@ TEST_P(RemoteTest, SharedRemoteSyncOnlyBlocksCallingSequence) {
// See https://crbug.com/1016022.
const scoped_refptr<base::SequencedTaskRunner> bound_task_runner =
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::WithBaseSyncPrimitives()});
base::ThreadPool::CreateSequencedTaskRunner(
{base::WithBaseSyncPrimitives()});
PendingRemote<mojom::SharedRemoteSyncTest> pending_remote;
auto receiver = pending_remote.InitWithNewPipeAndPassReceiver();

@ -10,6 +10,7 @@
#include "base/run_loop.h"
#include "base/sequence_token.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/test/bind_test_util.h"
#include "base/test/task_environment.h"
#include "base/threading/thread.h"
@ -252,7 +253,7 @@ template <typename Interface>
class TestSyncServiceSequence {
public:
TestSyncServiceSequence()
: task_runner_(base::CreateSequencedTaskRunner({base::ThreadPool()})),
: task_runner_(base::ThreadPool::CreateSequencedTaskRunner({})),
ping_called_(false) {}
void SetUp(InterfaceRequest<Interface> request) {
@ -432,8 +433,7 @@ void RunTestOnSequencedTaskRunner(
std::unique_ptr<SequencedTaskRunnerTestBase> test) {
base::RunLoop run_loop;
test->Init(run_loop.QuitClosure());
base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::WithBaseSyncPrimitives()})
base::ThreadPool::CreateSequencedTaskRunner({base::WithBaseSyncPrimitives()})
->PostTask(FROM_HERE,
base::BindOnce(&SequencedTaskRunnerTestBase::RunTest,
base::Unretained(test.release())));

@ -17,6 +17,7 @@
#include "base/sequenced_task_runner.h"
#include "base/synchronization/lock.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/thread_annotations.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "mojo/public/cpp/system/simple_watcher.h"
@ -184,8 +185,8 @@ void DataPipeProducer::InitializeNewRequest(CompletionCallback callback) {
// TODO(crbug.com/924416): Re-evaluate how TaskPriority is set here and in
// other file URL-loading-related code. Some callers require USER_VISIBLE
// (i.e., BEST_EFFORT is not enough).
auto file_task_runner = base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::USER_VISIBLE});
auto file_task_runner = base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_VISIBLE});
sequence_state_ = new SequenceState(
std::move(producer_), file_task_runner,
base::BindOnce(&DataPipeProducer::OnWriteComplete,

@ -69,6 +69,7 @@
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread.h"
#include "net/base/address_tracker_linux.h"
@ -212,7 +213,7 @@ NetworkChangeNotifierAndroid::NetworkChangeNotifierAndroid(
base::android::SDK_VERSION_P) {
// |blocking_thread_objects_| will live on this runner.
scoped_refptr<base::SequencedTaskRunner> blocking_thread_runner =
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock()});
base::ThreadPool::CreateSequencedTaskRunner({base::MayBlock()});
blocking_thread_objects_ =
std::unique_ptr<BlockingThreadObjects, base::OnTaskRunnerDeleter>(
new BlockingThreadObjects(),

@ -14,6 +14,7 @@
#include "base/location.h"
#include "base/logging.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/threading/thread_restrictions.h"
@ -80,10 +81,10 @@ DirectoryLister::~DirectoryLister() {
}
void DirectoryLister::Start() {
base::PostTask(FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&Core::Start, core_));
base::ThreadPool::PostTask(
FROM_HERE,
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&Core::Start, core_));
}
void DirectoryLister::Cancel() {

@ -11,6 +11,7 @@
#include "base/sequenced_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread.h"
#include "net/base/address_tracker_linux.h"
#include "net/dns/dns_config_service_posix.h"
@ -86,8 +87,8 @@ void NetworkChangeNotifierLinux::BlockingThreadObjects::OnLinkChanged() {
NetworkChangeNotifierLinux::NetworkChangeNotifierLinux(
const std::unordered_set<std::string>& ignored_interfaces)
: NetworkChangeNotifier(NetworkChangeCalculatorParamsLinux()),
blocking_thread_runner_(base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock()})),
blocking_thread_runner_(
base::ThreadPool::CreateSequencedTaskRunner({base::MayBlock()})),
blocking_thread_objects_(
new BlockingThreadObjects(ignored_interfaces),
// Ensure |blocking_thread_objects_| lives on

@ -18,6 +18,7 @@
#include "base/single_thread_task_runner.h"
#include "base/task/post_task.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/task_runner_util.h"
#include "base/threading/thread.h"
#include "base/threading/thread_task_runner_handle.h"
@ -38,8 +39,8 @@ NetworkChangeNotifierWin::NetworkChangeNotifierWin()
: NetworkChangeNotifier(NetworkChangeCalculatorParamsWin()),
is_watching_(false),
sequential_failures_(0),
blocking_task_runner_(base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock()})),
blocking_task_runner_(
base::ThreadPool::CreateSequencedTaskRunner({base::MayBlock()})),
last_computed_connection_type_(RecomputeCurrentConnectionType()),
last_announced_offline_(last_computed_connection_type_ ==
CONNECTION_NONE) {

@ -6,6 +6,7 @@
#include "base/run_loop.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/test/task_environment.h"
#include "net/base/test_completion_callback.h"
#include "net/cert/cert_verify_proc.h"
@ -102,10 +103,9 @@ class CertVerifyProcBuiltinTest : public ::testing::Test {
CertVerifyResult* verify_result,
CompletionOnceCallback callback) {
verify_result->DetachFromSequence();
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&VerifyOnWorkerThread, verify_proc_, std::move(cert),
hostname, flags, additional_trust_anchors,
verify_result),

@ -8,6 +8,7 @@
#include "base/bind_helpers.h"
#include "base/memory/weak_ptr.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_restrictions.h"
#include "base/trace_event/trace_event.h"
#include "net/base/net_errors.h"
@ -114,10 +115,9 @@ void InternalRequest::Start(const scoped_refptr<CertVerifyProc>& verify_proc,
flags &= ~CertVerifyProc::VERIFY_REV_CHECKING_REQUIRED_LOCAL_ANCHORS;
}
DCHECK(config.crl_set);
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&DoVerifyOnWorkerThread, verify_proc, params.certificate(),
params.hostname(), params.ocsp_response(),
params.sct_list(), flags, config.crl_set,

@ -20,6 +20,7 @@
#include "base/macros.h"
#include "base/observer_list_threadsafe.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
#include "crypto/nss_util_internal.h"
#include "crypto/scoped_nss_types.h"
@ -96,10 +97,9 @@ NSSCertDatabase::NSSCertDatabase(crypto::ScopedPK11Slot public_slot,
NSSCertDatabase::~NSSCertDatabase() = default;
void NSSCertDatabase::ListCerts(ListCertsCallback callback) {
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&NSSCertDatabase::ListCertsImpl, crypto::ScopedPK11Slot()),
std::move(callback));
}
@ -107,20 +107,18 @@ void NSSCertDatabase::ListCerts(ListCertsCallback callback) {
void NSSCertDatabase::ListCertsInSlot(ListCertsCallback callback,
PK11SlotInfo* slot) {
DCHECK(slot);
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&NSSCertDatabase::ListCertsImpl,
crypto::ScopedPK11Slot(PK11_ReferenceSlot(slot))),
std::move(callback));
}
void NSSCertDatabase::ListCertsInfo(ListCertsInfoCallback callback) {
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&NSSCertDatabase::ListCertsInfoImpl,
/*slot=*/nullptr,
/*add_certs_info=*/true),
@ -342,10 +340,9 @@ bool NSSCertDatabase::DeleteCertAndKey(CERTCertificate* cert) {
void NSSCertDatabase::DeleteCertAndKeyAsync(ScopedCERTCertificate cert,
DeleteCertCallback callback) {
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&NSSCertDatabase::DeleteCertAndKeyImplScoped,
std::move(cert)),
base::BindOnce(&NSSCertDatabase::NotifyCertRemovalAndCallBack,

@ -16,6 +16,7 @@
#include "base/location.h"
#include "base/stl_util.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/scoped_blocking_call.h"
namespace net {
@ -41,19 +42,17 @@ void NSSCertDatabaseChromeOS::SetSystemSlot(
void NSSCertDatabaseChromeOS::ListCerts(
NSSCertDatabase::ListCertsCallback callback) {
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&NSSCertDatabaseChromeOS::ListCertsImpl, profile_filter_),
std::move(callback));
}
void NSSCertDatabaseChromeOS::ListCertsInfo(ListCertsInfoCallback callback) {
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&NSSCertDatabaseChromeOS::ListCertsInfoImpl,
profile_filter_, /*slot=*/GetSystemSlot(),
/*add_certs_info=*/true),

@ -18,6 +18,7 @@
#include "base/strings/string_util.h"
#include "base/strings/stringprintf.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/test/metrics/histogram_tester.h"
#include "base/test/scoped_feature_list.h"
#include "base/third_party/dynamic_annotations/dynamic_annotations.h"
@ -4330,8 +4331,8 @@ TEST_F(DiskCacheBackendTest, DISABLED_SimpleCachePrioritizedEntryOrder) {
// priority order.
disk_cache::SimpleBackendImpl* simple_cache =
static_cast<disk_cache::SimpleBackendImpl*>(cache_.get());
auto task_runner = base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::TaskPriority::USER_VISIBLE, base::MayBlock()});
auto task_runner = base::ThreadPool::CreateSequencedTaskRunner(
{base::TaskPriority::USER_VISIBLE, base::MayBlock()});
simple_cache->SetTaskRunnerForTesting(task_runner);
// Create three entries. Priority order is 3, 1, 2 because 3 has the highest
@ -4422,8 +4423,8 @@ TEST_F(DiskCacheBackendTest, SimpleCacheFIFOEntryOrder) {
// priority order.
disk_cache::SimpleBackendImpl* simple_cache =
static_cast<disk_cache::SimpleBackendImpl*>(cache_.get());
auto task_runner = base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::TaskPriority::USER_VISIBLE, base::MayBlock()});
auto task_runner = base::ThreadPool::CreateSequencedTaskRunner(
{base::TaskPriority::USER_VISIBLE, base::MayBlock()});
simple_cache->SetTaskRunnerForTesting(task_runner);
// Create three entries. If their priority was honored, they'd run in order

@ -15,6 +15,7 @@
#include "base/logging.h"
#include "base/macros.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "net/base/net_errors.h"
#include "net/disk_cache/blockfile/in_flight_io.h"
#include "net/disk_cache/disk_cache.h"
@ -121,10 +122,10 @@ void FileInFlightIO::PostRead(disk_cache::File *file, void* buf, size_t buf_len,
new FileBackgroundIO(file, buf, buf_len, offset, callback, this));
file->AddRef(); // Balanced on OnOperationComplete()
base::PostTask(FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&FileBackgroundIO::Read, operation.get()));
base::ThreadPool::PostTask(
FROM_HERE,
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&FileBackgroundIO::Read, operation.get()));
OnOperationPosted(operation.get());
}
@ -135,10 +136,10 @@ void FileInFlightIO::PostWrite(disk_cache::File* file, const void* buf,
new FileBackgroundIO(file, buf, buf_len, offset, callback, this));
file->AddRef(); // Balanced on OnOperationComplete()
base::PostTask(FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&FileBackgroundIO::Write, operation.get()));
base::ThreadPool::PostTask(
FROM_HERE,
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&FileBackgroundIO::Write, operation.get()));
OnOperationPosted(operation.get());
}

@ -13,6 +13,7 @@
#include "base/logging.h"
#include "base/run_loop.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/task/thread_pool/thread_pool_instance.h"
#include "net/base/net_errors.h"
#include "net/disk_cache/disk_cache.h"
@ -73,9 +74,8 @@ bool File::Read(void* buffer, size_t buffer_len, size_t offset,
return false;
}
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::TaskPriority::USER_BLOCKING, base::MayBlock()},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::TaskPriority::USER_BLOCKING, base::MayBlock()},
base::BindOnce(&File::DoRead, base::Unretained(this), buffer, buffer_len,
offset),
base::BindOnce(&File::OnOperationComplete, this, callback));
@ -102,9 +102,8 @@ bool File::Write(const void* buffer, size_t buffer_len, size_t offset,
// finish before it reads from the network again.
// TODO(fdoray): Consider removing this from the critical path of network
// requests and changing the priority to BACKGROUND.
base::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::TaskPriority::USER_BLOCKING, base::MayBlock()},
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE, {base::TaskPriority::USER_BLOCKING, base::MayBlock()},
base::BindOnce(&File::DoWrite, base::Unretained(this), buffer, buffer_len,
offset),
base::BindOnce(&File::OnOperationComplete, this, callback));

@ -13,6 +13,7 @@
#include "base/strings/stringprintf.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "base/threading/thread_restrictions.h"
#include "build/build_config.h"
@ -140,11 +141,10 @@ bool DelayedCacheCleanup(const base::FilePath& full_path) {
return false;
}
base::PostTask(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&CleanupCallback, path, name_str));
base::ThreadPool::PostTask(FROM_HERE,
{base::MayBlock(), base::TaskPriority::BEST_EFFORT,
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&CleanupCallback, path, name_str));
return true;
}

@ -3,6 +3,7 @@
// found in the LICENSE file.
#include "net/disk_cache/simple/simple_backend_impl.h"
#include "base/task/thread_pool.h"
#include <algorithm>
#include <cstdlib>
@ -226,9 +227,8 @@ SimpleBackendImpl::SimpleBackendImpl(
file_tracker_(file_tracker ? file_tracker
: g_simple_file_tracker.Pointer()),
path_(path),
cache_runner_(base::CreateSequencedTaskRunner(
{base::ThreadPool(), base::MayBlock(),
base::TaskPriority::USER_BLOCKING,
cache_runner_(base::ThreadPool::CreateSequencedTaskRunner(
{base::MayBlock(), base::TaskPriority::USER_BLOCKING,
base::TaskShutdownBehavior::BLOCK_SHUTDOWN})),
orig_max_size_(max_bytes),
entry_operations_mode_((cache_type == net::DISK_CACHE ||
@ -259,8 +259,8 @@ void SimpleBackendImpl::SetTaskRunnerForTesting(
}
net::Error SimpleBackendImpl::Init(CompletionOnceCallback completion_callback) {
auto worker_pool = base::CreateTaskRunner(
{base::ThreadPool(), base::MayBlock(), base::WithBaseSyncPrimitives(),
auto worker_pool = base::ThreadPool::CreateTaskRunner(
{base::MayBlock(), base::WithBaseSyncPrimitives(),
base::TaskPriority::USER_BLOCKING,
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN});

@ -14,6 +14,7 @@
#include "base/macros.h"
#include "base/memory/free_deleter.h"
#include "base/task/post_task.h"
#include "base/task/thread_pool.h"
#include "net/base/address_list.h"
#include "net/base/ip_address.h"
#include "net/base/ip_endpoint.h"
@ -44,11 +45,11 @@ class AddressSorterWin : public AddressSorter {
public:
static void Start(const AddressList& list, CallbackType callback) {
auto job = base::WrapRefCounted(new Job(list, std::move(callback)));
base::PostTaskAndReply(FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&Job::Run, job),
base::BindOnce(&Job::OnComplete, job));
base::ThreadPool::PostTaskAndReply(
FROM_HERE,
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&Job::Run, job),
base::BindOnce(&Job::OnComplete, job));
}
private:

@ -23,6 +23,7 @@
#include "net/dns/public/dns_protocol.h"
#include "base/bind.h"
#include "base/task/thread_pool.h"
#include "testing/gtest/include/gtest/gtest.h"
#if defined(OS_ANDROID)
@ -206,7 +207,7 @@ TEST(DnsConfigServicePosixTest, DestroyOnDifferentThread) {
base::test::TaskEnvironment task_environment;
scoped_refptr<base::SequencedTaskRunner> runner =
base::CreateSequencedTaskRunner({base::ThreadPool(), base::MayBlock()});
base::ThreadPool::CreateSequencedTaskRunner({base::MayBlock()});
std::unique_ptr<internal::DnsConfigServicePosix, base::OnTaskRunnerDeleter>
service(new internal::DnsConfigServicePosix(),
base::OnTaskRunnerDeleter(runner));

@ -3,6 +3,7 @@
// found in the LICENSE file.
#include "net/dns/host_resolver_manager.h"
#include "base/task/thread_pool.h"
#if defined(OS_WIN)
#include <Winsock2.h>
@ -2705,8 +2706,8 @@ HostResolverManager::HostResolverManager(
DCHECK_GE(dispatcher_->num_priorities(), static_cast<size_t>(NUM_PRIORITIES));
proc_task_runner_ = base::CreateTaskRunner(
{base::ThreadPool(), base::MayBlock(), priority_mode.Get(),
proc_task_runner_ = base::ThreadPool::CreateTaskRunner(
{base::MayBlock(), priority_mode.Get(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN});
#if defined(OS_WIN)
@ -3594,10 +3595,9 @@ bool HostResolverManager::IsGloballyReachable(const IPAddress& dest,
void HostResolverManager::RunLoopbackProbeJob() {
// Run this asynchronously as it can take 40-100ms and should not block
// initialization.
base::PostTaskAndReplyWithResult(
base::ThreadPool::PostTaskAndReplyWithResult(
FROM_HERE,
{base::ThreadPool(), base::MayBlock(),
base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
{base::MayBlock(), base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN},
base::BindOnce(&HaveOnlyLoopbackAddresses),
base::BindOnce(&HostResolverManager::SetHaveOnlyLoopbackAddresses,
weak_ptr_factory_.GetWeakPtr()));

Some files were not shown because too many files have changed in this diff Show More