OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 // OneShotTimer and RepeatingTimer provide a simple timer API. As the names | 5 // This file has moved, please use the new location. |
6 // suggest, OneShotTimer calls you back once after a time delay expires. | 6 // TODO(avi): Remove this file when all users have been updated. |
7 // RepeatingTimer on the other hand calls you back periodically with the | 7 #include "base/timer/timer.h" |
8 // prescribed time interval. | |
9 // | |
10 // OneShotTimer and RepeatingTimer both cancel the timer when they go out of | |
11 // scope, which makes it easy to ensure that you do not get called when your | |
12 // object has gone out of scope. Just instantiate a OneShotTimer or | |
13 // RepeatingTimer as a member variable of the class for which you wish to | |
14 // receive timer events. | |
15 // | |
16 // Sample RepeatingTimer usage: | |
17 // | |
18 // class MyClass { | |
19 // public: | |
20 // void StartDoingStuff() { | |
21 // timer_.Start(FROM_HERE, TimeDelta::FromSeconds(1), | |
22 // this, &MyClass::DoStuff); | |
23 // } | |
24 // void StopDoingStuff() { | |
25 // timer_.Stop(); | |
26 // } | |
27 // private: | |
28 // void DoStuff() { | |
29 // // This method is called every second to do stuff. | |
30 // ... | |
31 // } | |
32 // base::RepeatingTimer<MyClass> timer_; | |
33 // }; | |
34 // | |
35 // Both OneShotTimer and RepeatingTimer also support a Reset method, which | |
36 // allows you to easily defer the timer event until the timer delay passes once | |
37 // again. So, in the above example, if 0.5 seconds have already passed, | |
38 // calling Reset on timer_ would postpone DoStuff by another 1 second. In | |
39 // other words, Reset is shorthand for calling Stop and then Start again with | |
40 // the same arguments. | |
41 // | |
42 // NOTE: These APIs are not thread safe. Always call from the same thread. | |
43 | |
44 #ifndef BASE_TIMER_H_ | |
45 #define BASE_TIMER_H_ | |
46 | |
47 // IMPORTANT: If you change timer code, make sure that all tests (including | |
48 // disabled ones) from timer_unittests.cc pass locally. Some are disabled | |
49 // because they're flaky on the buildbot, but when you run them locally you | |
50 // should be able to tell the difference. | |
51 | |
52 #include "base/base_export.h" | |
53 #include "base/bind.h" | |
54 #include "base/bind_helpers.h" | |
55 #include "base/callback.h" | |
56 #include "base/location.h" | |
57 #include "base/time.h" | |
58 | |
59 namespace base { | |
60 | |
61 class BaseTimerTaskInternal; | |
62 class MessageLoop; | |
63 | |
64 //----------------------------------------------------------------------------- | |
65 // This class wraps MessageLoop::PostDelayedTask to manage delayed and repeating | |
66 // tasks. It must be destructed on the same thread that starts tasks. There are | |
67 // DCHECKs in place to verify this. | |
68 // | |
69 class BASE_EXPORT Timer { | |
70 public: | |
71 // Construct a timer in repeating or one-shot mode. Start or SetTaskInfo must | |
72 // be called later to set task info. |retain_user_task| determines whether the | |
73 // user_task is retained or reset when it runs or stops. | |
74 Timer(bool retain_user_task, bool is_repeating); | |
75 | |
76 // Construct a timer with retained task info. | |
77 Timer(const tracked_objects::Location& posted_from, | |
78 TimeDelta delay, | |
79 const base::Closure& user_task, | |
80 bool is_repeating); | |
81 | |
82 virtual ~Timer(); | |
83 | |
84 // Returns true if the timer is running (i.e., not stopped). | |
85 bool IsRunning() const { | |
86 return is_running_; | |
87 } | |
88 | |
89 // Returns the current delay for this timer. | |
90 TimeDelta GetCurrentDelay() const { | |
91 return delay_; | |
92 } | |
93 | |
94 // Start the timer to run at the given |delay| from now. If the timer is | |
95 // already running, it will be replaced to call the given |user_task|. | |
96 void Start(const tracked_objects::Location& posted_from, | |
97 TimeDelta delay, | |
98 const base::Closure& user_task); | |
99 | |
100 // Call this method to stop and cancel the timer. It is a no-op if the timer | |
101 // is not running. | |
102 void Stop(); | |
103 | |
104 // Call this method to reset the timer delay. The user_task_ must be set. If | |
105 // the timer is not running, this will start it by posting a task. | |
106 void Reset(); | |
107 | |
108 const base::Closure& user_task() const { return user_task_; } | |
109 const TimeTicks& desired_run_time() const { return desired_run_time_; } | |
110 | |
111 protected: | |
112 // Used to initiate a new delayed task. This has the side-effect of disabling | |
113 // scheduled_task_ if it is non-null. | |
114 void SetTaskInfo(const tracked_objects::Location& posted_from, | |
115 TimeDelta delay, | |
116 const base::Closure& user_task); | |
117 | |
118 private: | |
119 friend class BaseTimerTaskInternal; | |
120 | |
121 // Allocates a new scheduled_task_ and posts it on the current MessageLoop | |
122 // with the given |delay|. scheduled_task_ must be NULL. scheduled_run_time_ | |
123 // and desired_run_time_ are reset to Now() + delay. | |
124 void PostNewScheduledTask(TimeDelta delay); | |
125 | |
126 // Disable scheduled_task_ and abandon it so that it no longer refers back to | |
127 // this object. | |
128 void AbandonScheduledTask(); | |
129 | |
130 // Called by BaseTimerTaskInternal when the MessageLoop runs it. | |
131 void RunScheduledTask(); | |
132 | |
133 // Stop running task (if any) and abandon scheduled task (if any). | |
134 void StopAndAbandon() { | |
135 Stop(); | |
136 AbandonScheduledTask(); | |
137 } | |
138 | |
139 // When non-NULL, the scheduled_task_ is waiting in the MessageLoop to call | |
140 // RunScheduledTask() at scheduled_run_time_. | |
141 BaseTimerTaskInternal* scheduled_task_; | |
142 | |
143 // Location in user code. | |
144 tracked_objects::Location posted_from_; | |
145 // Delay requested by user. | |
146 TimeDelta delay_; | |
147 // user_task_ is what the user wants to be run at desired_run_time_. | |
148 base::Closure user_task_; | |
149 | |
150 // The estimated time that the MessageLoop will run the scheduled_task_ that | |
151 // will call RunScheduledTask(). | |
152 TimeTicks scheduled_run_time_; | |
153 | |
154 // The desired run time of user_task_. The user may update this at any time, | |
155 // even if their previous request has not run yet. If desired_run_time_ is | |
156 // greater than scheduled_run_time_, a continuation task will be posted to | |
157 // wait for the remaining time. This allows us to reuse the pending task so as | |
158 // not to flood the MessageLoop with orphaned tasks when the user code | |
159 // excessively Stops and Starts the timer. | |
160 TimeTicks desired_run_time_; | |
161 | |
162 // Thread ID of current MessageLoop for verifying single-threaded usage. | |
163 int thread_id_; | |
164 | |
165 // Repeating timers automatically post the task again before calling the task | |
166 // callback. | |
167 const bool is_repeating_; | |
168 | |
169 // If true, hold on to the user_task_ closure object for reuse. | |
170 const bool retain_user_task_; | |
171 | |
172 // If true, user_task_ is scheduled to run sometime in the future. | |
173 bool is_running_; | |
174 | |
175 DISALLOW_COPY_AND_ASSIGN(Timer); | |
176 }; | |
177 | |
178 //----------------------------------------------------------------------------- | |
179 // This class is an implementation detail of OneShotTimer and RepeatingTimer. | |
180 // Please do not use this class directly. | |
181 template <class Receiver, bool kIsRepeating> | |
182 class BaseTimerMethodPointer : public Timer { | |
183 public: | |
184 typedef void (Receiver::*ReceiverMethod)(); | |
185 | |
186 // This is here to work around the fact that Timer::Start is "hidden" by the | |
187 // Start definition below, rather than being overloaded. | |
188 // TODO(tim): We should remove uses of BaseTimerMethodPointer::Start below | |
189 // and convert callers to use the base::Closure version in Timer::Start, | |
190 // see bug 148832. | |
191 using Timer::Start; | |
192 | |
193 BaseTimerMethodPointer() : Timer(kIsRepeating, kIsRepeating) {} | |
194 | |
195 // Start the timer to run at the given |delay| from now. If the timer is | |
196 // already running, it will be replaced to call a task formed from | |
197 // |reviewer->*method|. | |
198 void Start(const tracked_objects::Location& posted_from, | |
199 TimeDelta delay, | |
200 Receiver* receiver, | |
201 ReceiverMethod method) { | |
202 Timer::Start(posted_from, delay, | |
203 base::Bind(method, base::Unretained(receiver))); | |
204 } | |
205 }; | |
206 | |
207 //----------------------------------------------------------------------------- | |
208 // A simple, one-shot timer. See usage notes at the top of the file. | |
209 template <class Receiver> | |
210 class OneShotTimer : public BaseTimerMethodPointer<Receiver, false> {}; | |
211 | |
212 //----------------------------------------------------------------------------- | |
213 // A simple, repeating timer. See usage notes at the top of the file. | |
214 template <class Receiver> | |
215 class RepeatingTimer : public BaseTimerMethodPointer<Receiver, true> {}; | |
216 | |
217 //----------------------------------------------------------------------------- | |
218 // A Delay timer is like The Button from Lost. Once started, you have to keep | |
219 // calling Reset otherwise it will call the given method in the MessageLoop | |
220 // thread. | |
221 // | |
222 // Once created, it is inactive until Reset is called. Once |delay| seconds have | |
223 // passed since the last call to Reset, the callback is made. Once the callback | |
224 // has been made, it's inactive until Reset is called again. | |
225 // | |
226 // If destroyed, the timeout is canceled and will not occur even if already | |
227 // inflight. | |
228 template <class Receiver> | |
229 class DelayTimer : protected Timer { | |
230 public: | |
231 typedef void (Receiver::*ReceiverMethod)(); | |
232 | |
233 DelayTimer(const tracked_objects::Location& posted_from, | |
234 TimeDelta delay, | |
235 Receiver* receiver, | |
236 ReceiverMethod method) | |
237 : Timer(posted_from, delay, | |
238 base::Bind(method, base::Unretained(receiver)), | |
239 false) {} | |
240 | |
241 void Reset() { Timer::Reset(); } | |
242 }; | |
243 | |
244 } // namespace base | |
245 | |
246 #endif // BASE_TIMER_H_ | |
OLD | NEW |