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

Side by Side Diff: base/timer.h

Issue 18063004: Move timing files into base/time, install forwarding headers. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: ios Created 7 years, 5 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 | Annotate | Revision Log
« no previous file with comments | « base/time_win_unittest.cc ('k') | base/timer.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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_
OLDNEW
« no previous file with comments | « base/time_win_unittest.cc ('k') | base/timer.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698