1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
// Copyright 2018 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "content/browser/startup_helper.h"
#include <algorithm>
#include <memory>
#include <set>
#include <string>
#include "base/base_switches.h"
#include "base/command_line.h"
#include "base/system/sys_info.h"
#include "base/task/thread_pool/initialization_util.h"
#include "base/task/thread_pool/thread_pool_instance.h"
#include "build/build_config.h"
#include "content/common/thread_pool_util.h"
#include "content/public/common/content_switch_dependent_feature_overrides.h"
#include "content/public/common/content_switches.h"
namespace content {
std::unique_ptr<base::FieldTrialList> SetUpFieldTrialsAndFeatureList() {
std::unique_ptr<base::FieldTrialList> field_trial_list;
if (!base::FieldTrialList::GetInstance()) {
field_trial_list = std::make_unique<base::FieldTrialList>();
}
const base::CommandLine* command_line =
base::CommandLine::ForCurrentProcess();
// Ensure any field trials specified on the command line are initialized.
if (command_line->HasSwitch(::switches::kForceFieldTrials)) {
// Create field trials without activating them, so that this behaves in a
// consistent manner with field trials created from the server.
bool result = base::FieldTrialList::CreateTrialsFromString(
command_line->GetSwitchValueASCII(::switches::kForceFieldTrials));
CHECK(result) << "Invalid --" << ::switches::kForceFieldTrials
<< " list specified.";
}
base::FeatureList::InitInstance(
command_line->GetSwitchValueASCII(switches::kEnableFeatures),
command_line->GetSwitchValueASCII(switches::kDisableFeatures),
GetSwitchDependentFeatureOverrides(*command_line));
return field_trial_list;
}
namespace {
#if BUILDFLAG(IS_ANDROID)
// Mobile config, for iOS see ios/web/app/web_main_loop.cc.
constexpr size_t kThreadPoolDefaultMin = 6;
constexpr size_t kThreadPoolMax = 8;
constexpr double kThreadPoolCoresMultiplier = 0.6;
constexpr int kThreadPoolOffset = 0;
#else
// Desktop config.
constexpr size_t kThreadPoolDefaultMin = 16;
constexpr size_t kThreadPoolMax = 32;
constexpr double kThreadPoolCoresMultiplier = 0.6;
constexpr int kThreadPoolOffset = 0;
#endif
BASE_FEATURE(kBrowserThreadPoolAdjustment,
"BrowserThreadPoolAdjustment",
base::FEATURE_DISABLED_BY_DEFAULT);
const base::FeatureParam<int> kBrowserThreadPoolMin{
&kBrowserThreadPoolAdjustment, "min", kThreadPoolDefaultMin};
} // namespace
// TODO(scheduler-dev): Standardize thread pool logic and remove the need for
// specifying thread count manually.
void StartBrowserThreadPool() {
// Ensure we always support at least one thread regardless of the field trial
// param setting.
size_t min =
base::checked_cast<size_t>(std::max(kBrowserThreadPoolMin.Get(), 1));
base::ThreadPoolInstance::InitParams thread_pool_init_params = {
base::RecommendedMaxNumberOfThreadsInThreadGroup(
min, kThreadPoolMax, kThreadPoolCoresMultiplier, kThreadPoolOffset)};
#if BUILDFLAG(IS_WIN)
thread_pool_init_params.common_thread_pool_environment = base::
ThreadPoolInstance::InitParams::CommonThreadPoolEnvironment::COM_MTA;
#endif
// If a renderer lives in the browser process, adjust the number of
// threads in the foreground pool.
if (base::CommandLine::ForCurrentProcess()->HasSwitch(
switches::kSingleProcess)) {
thread_pool_init_params.max_num_foreground_threads =
std::max(GetMinForegroundThreadsInRendererThreadPool(),
thread_pool_init_params.max_num_foreground_threads);
}
base::ThreadPoolInstance::Get()->Start(thread_pool_init_params);
}
} // namespace content
|
