Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(119)

Side by Side Diff: base/task_scheduler/utils.cc

Issue 1906083002: TaskScheduler: Remove base/task_scheduler/utils.h/.cc (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@sched_2_stack
Patch Set: typos Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(Empty)
1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "base/task_scheduler/utils.h"
6
7 #include <utility>
8
9 #include "base/logging.h"
10 #include "base/memory/ptr_util.h"
11 #include "base/task_scheduler/delayed_task_manager.h"
12 #include "base/task_scheduler/priority_queue.h"
13 #include "base/task_scheduler/scheduler_task_executor.h"
14 #include "base/task_scheduler/sequence_sort_key.h"
15 #include "base/task_scheduler/task_tracker.h"
16 #include "base/time/time.h"
17
18 namespace base {
19 namespace internal {
20
21 bool PostTaskToExecutor(std::unique_ptr<Task> task,
22 scoped_refptr<Sequence> sequence,
23 SchedulerTaskExecutor* executor,
24 TaskTracker* task_tracker,
25 DelayedTaskManager* delayed_task_manager) {
26 DCHECK(task);
27 DCHECK(sequence);
28 DCHECK(executor);
29 DCHECK(task_tracker);
30 DCHECK(delayed_task_manager);
31
32 if (!task_tracker->WillPostTask(task.get()))
33 return false;
34
35 if (task->delayed_run_time.is_null()) {
36 executor->PostTaskWithSequence(std::move(task), std::move(sequence));
37 } else {
38 delayed_task_manager->AddDelayedTask(std::move(task), std::move(sequence),
39 executor);
40 }
41
42 return true;
43 }
44
45 bool AddTaskToSequenceAndPriorityQueue(std::unique_ptr<Task> task,
46 scoped_refptr<Sequence> sequence,
47 PriorityQueue* priority_queue) {
48 DCHECK(task);
49 DCHECK(sequence);
50 DCHECK(priority_queue);
51
52 // Confirm that |task| is ready to run (its delayed run time is either null or
53 // in the past).
54 DCHECK_LE(task->delayed_run_time, TimeTicks::Now());
55
56 const bool sequence_was_empty = sequence->PushTask(std::move(task));
57 if (sequence_was_empty) {
58 // Insert |sequence| in |priority_queue| if it was empty before |task| was
59 // inserted into it. Otherwise, one of these must be true:
60 // - |sequence| is already in a PriorityQueue (not necessarily
61 // |priority_queue|), or,
62 // - A worker thread is running a Task from |sequence|. It will insert
63 // |sequence| in a PriorityQueue once it's done running the Task.
64 const auto sequence_sort_key = sequence->GetSortKey();
65 priority_queue->BeginTransaction()->Push(
66 WrapUnique(new PriorityQueue::SequenceAndSortKey(std::move(sequence),
67 sequence_sort_key)));
68 }
69
70 return sequence_was_empty;
71 }
72
73 } // namespace internal
74 } // namespace base
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698