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
|
// Copyright 2014 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 "components/scheduler/child/single_thread_idle_task_runner.h"
#include "base/location.h"
#include "base/trace_event/trace_event.h"
namespace scheduler {
SingleThreadIdleTaskRunner::SingleThreadIdleTaskRunner(
scoped_refptr<base::SingleThreadTaskRunner> idle_priority_task_runner,
scoped_refptr<base::SingleThreadTaskRunner> after_wakeup_task_runner,
Delegate* delegate,
const char* tracing_category)
: idle_priority_task_runner_(idle_priority_task_runner),
after_wakeup_task_runner_(after_wakeup_task_runner),
delegate_(delegate),
tracing_category_(tracing_category),
weak_factory_(this) {
DCHECK(!idle_priority_task_runner_ ||
idle_priority_task_runner_->RunsTasksOnCurrentThread());
DCHECK(!after_wakeup_task_runner_ ||
after_wakeup_task_runner_->RunsTasksOnCurrentThread());
weak_scheduler_ptr_ = weak_factory_.GetWeakPtr();
}
SingleThreadIdleTaskRunner::~SingleThreadIdleTaskRunner() {
}
SingleThreadIdleTaskRunner::Delegate::Delegate() {
}
SingleThreadIdleTaskRunner::Delegate::~Delegate() {
}
bool SingleThreadIdleTaskRunner::RunsTasksOnCurrentThread() const {
return idle_priority_task_runner_->RunsTasksOnCurrentThread();
}
void SingleThreadIdleTaskRunner::PostIdleTask(
const tracked_objects::Location& from_here,
const IdleTask& idle_task) {
delegate_->OnIdleTaskPosted();
idle_priority_task_runner_->PostTask(
from_here, base::Bind(&SingleThreadIdleTaskRunner::RunTask,
weak_scheduler_ptr_, idle_task));
}
void SingleThreadIdleTaskRunner::PostNonNestableIdleTask(
const tracked_objects::Location& from_here,
const IdleTask& idle_task) {
delegate_->OnIdleTaskPosted();
idle_priority_task_runner_->PostNonNestableTask(
from_here, base::Bind(&SingleThreadIdleTaskRunner::RunTask,
weak_scheduler_ptr_, idle_task));
}
void SingleThreadIdleTaskRunner::PostIdleTaskAfterWakeup(
const tracked_objects::Location& from_here,
const IdleTask& idle_task) {
// Don't signal posting of idle task to the delegate here, wait until the
// after-wakeup task posts the real idle task.
after_wakeup_task_runner_->PostTask(
FROM_HERE, base::Bind(&SingleThreadIdleTaskRunner::PostIdleTask,
weak_scheduler_ptr_, from_here, idle_task));
}
void SingleThreadIdleTaskRunner::RunTask(IdleTask idle_task) {
base::TimeTicks deadline = delegate_->WillProcessIdleTask();
TRACE_EVENT1(tracing_category_, "SingleThreadIdleTaskRunner::RunTask",
"allotted_time_ms",
(deadline - base::TimeTicks::Now()).InMillisecondsF());
idle_task.Run(deadline);
delegate_->DidProcessIdleTask();
}
} // namespace scheduler
|
