blob: bd4d984a5891c51aef4e6bf99861f67aa888c245 (
plain)
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
|
// Copyright 2017 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "third_party/blink/renderer/platform/scheduler/main_thread/main_thread_scheduler_helper.h"
#include "third_party/blink/renderer/platform/scheduler/child/task_queue_with_task_type.h"
#include "third_party/blink/renderer/platform/scheduler/main_thread/main_thread_task_queue.h"
namespace blink {
namespace scheduler {
using base::sequence_manager::TaskQueue;
MainThreadSchedulerHelper::MainThreadSchedulerHelper(
std::unique_ptr<base::sequence_manager::SequenceManager> sequence_manager,
MainThreadSchedulerImpl* main_thread_scheduler)
: SchedulerHelper(std::move(sequence_manager)),
main_thread_scheduler_(main_thread_scheduler),
default_task_queue_(
NewTaskQueue(MainThreadTaskQueue::QueueCreationParams(
MainThreadTaskQueue::QueueType::kDefault)
.SetShouldMonitorQuiescence(true))),
control_task_queue_(
NewTaskQueue(MainThreadTaskQueue::QueueCreationParams(
MainThreadTaskQueue::QueueType::kControl)
.SetShouldNotifyObservers(false))) {
InitDefaultQueues(default_task_queue_, control_task_queue_,
TaskType::kMainThreadTaskQueueDefault);
sequence_manager_->EnableCrashKeys("blink_scheduler_task_file_name",
"blink_scheduler_task_function_name");
}
MainThreadSchedulerHelper::~MainThreadSchedulerHelper() {
control_task_queue_->ShutdownTaskQueue();
default_task_queue_->ShutdownTaskQueue();
}
scoped_refptr<MainThreadTaskQueue>
MainThreadSchedulerHelper::DefaultMainThreadTaskQueue() {
return default_task_queue_;
}
scoped_refptr<TaskQueue> MainThreadSchedulerHelper::DefaultTaskQueue() {
return default_task_queue_;
}
scoped_refptr<MainThreadTaskQueue>
MainThreadSchedulerHelper::ControlMainThreadTaskQueue() {
return control_task_queue_;
}
scoped_refptr<TaskQueue> MainThreadSchedulerHelper::ControlTaskQueue() {
return control_task_queue_;
}
scoped_refptr<MainThreadTaskQueue> MainThreadSchedulerHelper::NewTaskQueue(
const MainThreadTaskQueue::QueueCreationParams& params) {
scoped_refptr<MainThreadTaskQueue> task_queue =
sequence_manager_->CreateTaskQueue<MainThreadTaskQueue>(
params.spec, params, main_thread_scheduler_);
if (params.fixed_priority)
task_queue->SetQueuePriority(params.fixed_priority.value());
return task_queue;
}
} // namespace scheduler
} // namespace blink
|
