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

Side by Side Diff: base/memory/weak_ptr.h

Issue 14299011: Remove all but one use of WeakPtrFactory::DetachFromThread. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Simplify change to IOThread. Created 7 years, 7 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 | « no previous file | base/memory/weak_ptr.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 (c) 2012 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 // Weak pointers are pointers to an object that do not affect its lifetime, 5 // Weak pointers are pointers to an object that do not affect its lifetime,
6 // and which may be invalidated (i.e. reset to NULL) by the object, or its 6 // and which may be invalidated (i.e. reset to NULL) by the object, or its
7 // owner, at any time, most commonly when the object is about to be deleted. 7 // owner, at any time, most commonly when the object is about to be deleted.
8 8
9 // Weak pointers are useful when an object needs to be accessed safely by one 9 // Weak pointers are useful when an object needs to be accessed safely by one
10 // or more objects other than its owner, and those callers can cope with the 10 // or more objects other than its owner, and those callers can cope with the
11 // object vanishing and e.g. tasks posted to it being silently dropped. 11 // object vanishing and e.g. tasks posted to it being silently dropped.
12 // Reference-counting such an object would complicate the ownership graph and 12 // Reference-counting such an object would complicate the ownership graph and
13 // make it harder to reason about the object's lifetime. 13 // make it harder to reason about the object's lifetime.
14 14
15 // EXAMPLE: 15 // EXAMPLE:
16 // 16 //
17 // class Controller { 17 // class Controller {
18 // public: 18 // public:
19 // void SpawnWorker() { Worker::StartNew(weak_factory_.GetWeakPtr()); } 19 // void SpawnWorker() { Worker::StartNew(weak_factory_.GetWeakPtr()); }
20 // void WorkComplete(const Result& result) { ... } 20 // void WorkComplete(const Result& result) { ... }
21 // private: 21 // private:
22 // // Member variables should appear before the WeakPtrFactory.
awong 2013/05/15 01:19:15 Explain why.
Wez 2013/05/15 22:51:50 Done.
22 // WeakPtrFactory<Controller> weak_factory_; 23 // WeakPtrFactory<Controller> weak_factory_;
23 // }; 24 // };
24 // 25 //
25 // class Worker { 26 // class Worker {
26 // public: 27 // public:
27 // static void StartNew(const WeakPtr<Controller>& controller) { 28 // static void StartNew(const WeakPtr<Controller>& controller) {
28 // Worker* worker = new Worker(controller); 29 // Worker* worker = new Worker(controller);
29 // // Kick off asynchronous processing... 30 // // Kick off asynchronous processing...
30 // } 31 // }
31 // private: 32 // private:
32 // Worker(const WeakPtr<Controller>& controller) 33 // Worker(const WeakPtr<Controller>& controller)
33 // : controller_(controller) {} 34 // : controller_(controller) {}
34 // void DidCompleteAsynchronousProcessing(const Result& result) { 35 // void DidCompleteAsynchronousProcessing(const Result& result) {
35 // if (controller_) 36 // if (controller_)
36 // controller_->WorkComplete(result); 37 // controller_->WorkComplete(result);
37 // } 38 // }
38 // WeakPtr<Controller> controller_; 39 // WeakPtr<Controller> controller_;
39 // }; 40 // };
40 // 41 //
41 // With this implementation a caller may use SpawnWorker() to dispatch multiple 42 // With this implementation a caller may use SpawnWorker() to dispatch multiple
42 // Workers and subsequently delete the Controller, without waiting for all 43 // Workers and subsequently delete the Controller, without waiting for all
43 // Workers to have completed. 44 // Workers to have completed.
44 45
45 // ------------------------- IMPORTANT: Thread-safety ------------------------- 46 // ------------------------- IMPORTANT: Thread-safety -------------------------
46 47
47 // Weak pointers must always be dereferenced and invalidated on the same thread 48 // Weak pointers must always be dereferenced and invalidated on the same thread
48 // otherwise checking the pointer would be racey. WeakPtrFactory enforces this 49 // otherwise checking the pointer would be racey.
49 // by binding itself to the current thread when a WeakPtr is first created
50 // and un-binding only when those pointers are invalidated. WeakPtrs may still
51 // be handed off to other threads, however, so long as they are only actually
52 // dereferenced on the originating thread. This includes posting tasks to the
53 // thread using base::Bind() to invoke a method on the object via the WeakPtr.
54 50
55 // Calling SupportsWeakPtr::DetachFromThread() can work around the limitations 51 // To check this, a WeakPtrFactory and valid WeakPtrs it has issued become bound
56 // above and cancel the thread binding of the object and all WeakPtrs pointing 52 // to the calling thread, either when one of the pointers is dereferenced, or
57 // to it, but it's not recommended and unsafe. See crbug.com/232143. 53 // when they are invalidated. When a factory's pointers are invalidated, the
54 // factory itself returns to being un-bound, and it and the object it dispenses
55 // pointers for may be moved to a new thread.
awong 2013/05/15 01:19:15 Would it be useful to list a reduction of the foll
Wez 2013/05/15 22:51:50 I've added that in. It feels to me a little too i
56
57 // This allows a WeakPtr to an object to be created on one thread, but used to
58 // post tasks to it on a second thread, so long as the WeakPtr is eventually
59 // invalidated (e.g. by the object being deleted) on the second thread.
60
61 // It also allows a WeakPtr to be created on one thread, and passed to a second,
62 // for instance to use to post tasks back to the object on the first thread.
58 63
59 #ifndef BASE_MEMORY_WEAK_PTR_H_ 64 #ifndef BASE_MEMORY_WEAK_PTR_H_
60 #define BASE_MEMORY_WEAK_PTR_H_ 65 #define BASE_MEMORY_WEAK_PTR_H_
61 66
62 #include "base/basictypes.h" 67 #include "base/basictypes.h"
63 #include "base/base_export.h" 68 #include "base/base_export.h"
64 #include "base/logging.h" 69 #include "base/logging.h"
65 #include "base/memory/ref_counted.h" 70 #include "base/memory/ref_counted.h"
66 #include "base/template_util.h" 71 #include "base/template_util.h"
67 #include "base/threading/thread_checker.h" 72 #include "base/threading/thread_checker.h"
68 73
69 namespace base { 74 namespace base {
70 75
71 template <typename T> class SupportsWeakPtr; 76 template <typename T> class SupportsWeakPtr;
72 template <typename T> class WeakPtr; 77 template <typename T> class WeakPtr;
73 78
74 namespace internal { 79 namespace internal {
75 // These classes are part of the WeakPtr implementation. 80 // These classes are part of the WeakPtr implementation.
76 // DO NOT USE THESE CLASSES DIRECTLY YOURSELF. 81 // DO NOT USE THESE CLASSES DIRECTLY YOURSELF.
77 82
78 class BASE_EXPORT WeakReference { 83 class BASE_EXPORT WeakReference {
79 public: 84 public:
80 // While Flag is bound to a specific thread, it may be deleted from another 85 // Although Flag is bound to a specific thread, it may be deleted from another
81 // via base::WeakPtr::~WeakPtr(). 86 // via base::WeakPtr::~WeakPtr().
82 class Flag : public RefCountedThreadSafe<Flag> { 87 class Flag : public RefCountedThreadSafe<Flag> {
83 public: 88 public:
84 Flag(); 89 Flag();
85 90
86 void Invalidate(); 91 void Invalidate();
87 bool IsValid() const; 92 bool IsValid() const;
88 93
89 void DetachFromThread() { thread_checker_.DetachFromThread(); } 94 // Remove this when crbug.com/234964 is addressed.
95 void DetachFromThreadHack() { thread_checker_.DetachFromThread(); }
90 96
91 private: 97 private:
92 friend class base::RefCountedThreadSafe<Flag>; 98 friend class base::RefCountedThreadSafe<Flag>;
93 99
94 ~Flag(); 100 ~Flag();
95 101
96 ThreadChecker thread_checker_; 102 ThreadChecker thread_checker_;
97 bool is_valid_; 103 bool is_valid_;
98 }; 104 };
99 105
(...skipping 13 matching lines...) Expand all
113 ~WeakReferenceOwner(); 119 ~WeakReferenceOwner();
114 120
115 WeakReference GetRef() const; 121 WeakReference GetRef() const;
116 122
117 bool HasRefs() const { 123 bool HasRefs() const {
118 return flag_.get() && !flag_->HasOneRef(); 124 return flag_.get() && !flag_->HasOneRef();
119 } 125 }
120 126
121 void Invalidate(); 127 void Invalidate();
122 128
123 // Indicates that this object will be used on another thread from now on. 129 // Remove this when crbug.com/234964 is addressed.
124 // Do not use this in new code. See crbug.com/232143. 130 void DetachFromThreadHack() {
125 void DetachFromThread() { 131 if (flag_) flag_->DetachFromThreadHack();
126 if (flag_) flag_->DetachFromThread();
127 } 132 }
128 133
129 private: 134 private:
130 mutable scoped_refptr<WeakReference::Flag> flag_; 135 mutable scoped_refptr<WeakReference::Flag> flag_;
131 }; 136 };
132 137
133 // This class simplifies the implementation of WeakPtr's type conversion 138 // This class simplifies the implementation of WeakPtr's type conversion
134 // constructor by avoiding the need for a public accessor for ref_. A 139 // constructor by avoiding the need for a public accessor for ref_. A
135 // WeakPtr<T> cannot access the private members of WeakPtr<U>, so this 140 // WeakPtr<T> cannot access the private members of WeakPtr<U>, so this
136 // base class gives us a way to access ref_ in a protected fashion. 141 // base class gives us a way to access ref_ in a protected fashion.
(...skipping 125 matching lines...) Expand 10 before | Expand all | Expand 10 after
262 DCHECK(ptr_); 267 DCHECK(ptr_);
263 weak_reference_owner_.Invalidate(); 268 weak_reference_owner_.Invalidate();
264 } 269 }
265 270
266 // Call this method to determine if any weak pointers exist. 271 // Call this method to determine if any weak pointers exist.
267 bool HasWeakPtrs() const { 272 bool HasWeakPtrs() const {
268 DCHECK(ptr_); 273 DCHECK(ptr_);
269 return weak_reference_owner_.HasRefs(); 274 return weak_reference_owner_.HasRefs();
270 } 275 }
271 276
272 // Indicates that this object will be used on another thread from now on.
273 // Do not use this in new code. See crbug.com/232143.
274 void DetachFromThread() {
275 DCHECK(ptr_);
276 weak_reference_owner_.DetachFromThread();
277 }
278
279 private: 277 private:
280 internal::WeakReferenceOwner weak_reference_owner_; 278 internal::WeakReferenceOwner weak_reference_owner_;
281 T* ptr_; 279 T* ptr_;
282 DISALLOW_IMPLICIT_CONSTRUCTORS(WeakPtrFactory); 280 DISALLOW_IMPLICIT_CONSTRUCTORS(WeakPtrFactory);
283 }; 281 };
284 282
285 // A class may extend from SupportsWeakPtr to let others take weak pointers to 283 // A class may extend from SupportsWeakPtr to let others take weak pointers to
286 // it. This avoids the class itself implementing boilerplate to dispense weak 284 // it. This avoids the class itself implementing boilerplate to dispense weak
287 // pointers. However, since SupportsWeakPtr's destructor won't invalidate 285 // pointers. However, since SupportsWeakPtr's destructor won't invalidate
288 // weak pointers to the class until after the derived class' members have been 286 // weak pointers to the class until after the derived class' members have been
289 // destroyed, its use can lead to subtle use-after-destroy issues. 287 // destroyed, its use can lead to subtle use-after-destroy issues.
290 template <class T> 288 template <class T>
291 class SupportsWeakPtr : public internal::SupportsWeakPtrBase { 289 class SupportsWeakPtr : public internal::SupportsWeakPtrBase {
292 public: 290 public:
293 SupportsWeakPtr() {} 291 SupportsWeakPtr() {}
294 292
295 WeakPtr<T> AsWeakPtr() { 293 WeakPtr<T> AsWeakPtr() {
296 return WeakPtr<T>(weak_reference_owner_.GetRef(), static_cast<T*>(this)); 294 return WeakPtr<T>(weak_reference_owner_.GetRef(), static_cast<T*>(this));
297 } 295 }
298 296
299 // Indicates that this object will be used on another thread from now on. 297 // Removes the binding, if any, from this object to a particular thread.
300 // Do not use this in new code. See crbug.com/232143. 298 // This is used in WebGraphicsContext3DInProcessCommandBufferImpl to work-
301 void DetachFromThread() { 299 // around access to cmmand buffer objects by more than one thread.
302 weak_reference_owner_.DetachFromThread(); 300 // Remove this when crbug.com/234964 is addressed.
301 void DetachFromThreadHack() {
302 weak_reference_owner_.DetachFromThreadHack();
303 } 303 }
304 304
305 protected: 305 protected:
306 ~SupportsWeakPtr() {} 306 ~SupportsWeakPtr() {}
307 307
308 private: 308 private:
309 internal::WeakReferenceOwner weak_reference_owner_; 309 internal::WeakReferenceOwner weak_reference_owner_;
310 DISALLOW_COPY_AND_ASSIGN(SupportsWeakPtr); 310 DISALLOW_COPY_AND_ASSIGN(SupportsWeakPtr);
311 }; 311 };
312 312
(...skipping 16 matching lines...) Expand all
329 // base::WeakPtr<Derived> ptr = derived.AsWeakPtr(); // Fails. 329 // base::WeakPtr<Derived> ptr = derived.AsWeakPtr(); // Fails.
330 330
331 template <typename Derived> 331 template <typename Derived>
332 WeakPtr<Derived> AsWeakPtr(Derived* t) { 332 WeakPtr<Derived> AsWeakPtr(Derived* t) {
333 return internal::SupportsWeakPtrBase::StaticAsWeakPtr<Derived>(t); 333 return internal::SupportsWeakPtrBase::StaticAsWeakPtr<Derived>(t);
334 } 334 }
335 335
336 } // namespace base 336 } // namespace base
337 337
338 #endif // BASE_MEMORY_WEAK_PTR_H_ 338 #endif // BASE_MEMORY_WEAK_PTR_H_
OLDNEW
« no previous file with comments | « no previous file | base/memory/weak_ptr.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698