OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef BASE_TASK_SCHEDULER_DELAYED_TASK_MANAGER_H_ | 5 #ifndef BASE_TASK_SCHEDULER_DELAYED_TASK_MANAGER_H_ |
6 #define BASE_TASK_SCHEDULER_DELAYED_TASK_MANAGER_H_ | 6 #define BASE_TASK_SCHEDULER_DELAYED_TASK_MANAGER_H_ |
7 | 7 |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <memory> | 10 #include <memory> |
11 #include <queue> | 11 #include <queue> |
12 #include <vector> | 12 #include <vector> |
13 | 13 |
14 #include "base/base_export.h" | 14 #include "base/base_export.h" |
15 #include "base/callback.h" | 15 #include "base/callback.h" |
16 #include "base/macros.h" | 16 #include "base/macros.h" |
17 #include "base/memory/ref_counted.h" | 17 #include "base/memory/ref_counted.h" |
18 #include "base/task_scheduler/scheduler_lock.h" | 18 #include "base/task_scheduler/scheduler_lock.h" |
19 #include "base/task_scheduler/sequence.h" | 19 #include "base/task_scheduler/sequence.h" |
20 #include "base/task_scheduler/task.h" | 20 #include "base/task_scheduler/task.h" |
21 #include "base/time/time.h" | 21 #include "base/time/time.h" |
22 | 22 |
23 namespace base { | 23 namespace base { |
24 namespace internal { | 24 namespace internal { |
25 | 25 |
26 class SchedulerTaskExecutor; | 26 class SchedulerThreadPoolInterface; |
27 | 27 |
28 // A DelayedTaskManager holds delayed Tasks until they become ripe for | 28 // A DelayedTaskManager holds delayed Tasks until they become ripe for |
29 // execution. When they become ripe for execution, it posts them to their | 29 // execution. When they become ripe for execution, it posts them to their |
30 // associated Sequence and SchedulerTaskExecutor. This class is thread-safe. | 30 // associated Sequence and SchedulerThreadPoolInterface. This class is thread- |
| 31 // safe. |
31 class BASE_EXPORT DelayedTaskManager { | 32 class BASE_EXPORT DelayedTaskManager { |
32 public: | 33 public: |
33 // |on_delayed_run_time_updated| is invoked when the delayed run time is | 34 // |on_delayed_run_time_updated| is invoked when the delayed run time is |
34 // updated as a result of adding a delayed task to the manager. | 35 // updated as a result of adding a delayed task to the manager. |
35 explicit DelayedTaskManager(const Closure& on_delayed_run_time_updated); | 36 explicit DelayedTaskManager(const Closure& on_delayed_run_time_updated); |
36 ~DelayedTaskManager(); | 37 ~DelayedTaskManager(); |
37 | 38 |
38 // Adds |task| to a queue of delayed tasks. The task will be posted to | 39 // Adds |task| to a queue of delayed tasks. The task will be posted to |
39 // |executor| as part of |sequence| the first time that PostReadyTasks() is | 40 // |thread_pool| as part of |sequence| the first time that PostReadyTasks() is |
40 // called while Now() is passed |task->delayed_run_time|. | 41 // called while Now() is passed |task->delayed_run_time|. |
41 // | 42 // |
42 // TODO(robliao): Find a concrete way to manage |executor|'s memory. It is | 43 // TODO(robliao): Find a concrete way to manage |thread_pool|'s memory. It is |
43 // never deleted in production, but it is better not to spread this assumption | 44 // never deleted in production, but it is better not to spread this assumption |
44 // throughout the scheduler. | 45 // throughout the scheduler. |
45 void AddDelayedTask(std::unique_ptr<Task> task, | 46 void AddDelayedTask(std::unique_ptr<Task> task, |
46 scoped_refptr<Sequence> sequence, | 47 scoped_refptr<Sequence> sequence, |
47 SchedulerTaskExecutor* executor); | 48 SchedulerThreadPoolInterface* thread_pool); |
48 | 49 |
49 // Posts delayed tasks that are ripe for execution. | 50 // Posts delayed tasks that are ripe for execution. |
50 // TODO(robliao): Call this from a service thread. | 51 // TODO(robliao): Call this from a service thread. |
51 void PostReadyTasks(); | 52 void PostReadyTasks(); |
52 | 53 |
53 // Returns the next time at which a delayed task will become ripe for | 54 // Returns the next time at which a delayed task will become ripe for |
54 // execution, or a null TimeTicks if there are no pending delayed tasks. | 55 // execution, or a null TimeTicks if there are no pending delayed tasks. |
55 TimeTicks GetDelayedRunTime() const; | 56 TimeTicks GetDelayedRunTime() const; |
56 | 57 |
57 private: | 58 private: |
(...skipping 20 matching lines...) Expand all Loading... |
78 // The index to assign to the next delayed task added to the manager. | 79 // The index to assign to the next delayed task added to the manager. |
79 uint64_t delayed_task_index_ = 0; | 80 uint64_t delayed_task_index_ = 0; |
80 | 81 |
81 DISALLOW_COPY_AND_ASSIGN(DelayedTaskManager); | 82 DISALLOW_COPY_AND_ASSIGN(DelayedTaskManager); |
82 }; | 83 }; |
83 | 84 |
84 } // namespace internal | 85 } // namespace internal |
85 } // namespace base | 86 } // namespace base |
86 | 87 |
87 #endif // BASE_TASK_SCHEDULER_DELAYED_TASK_MANAGER_H_ | 88 #endif // BASE_TASK_SCHEDULER_DELAYED_TASK_MANAGER_H_ |
OLD | NEW |