| OLD | NEW |
| 1 // Copyright 2013 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 #ifndef BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ | 5 #ifndef BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ |
| 6 #define BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ | 6 #define BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ |
| 7 | 7 |
| 8 #include <queue> | 8 #include <queue> |
| 9 #include <string> | 9 #include <string> |
| 10 | 10 |
| 11 #include "base/base_export.h" | 11 #include "base/base_export.h" |
| 12 #include "base/basictypes.h" | 12 #include "base/basictypes.h" |
| 13 #include "base/callback_forward.h" | 13 #include "base/callback_forward.h" |
| 14 #include "base/debug/task_annotator.h" | 14 #include "base/debug/task_annotator.h" |
| 15 #include "base/location.h" | 15 #include "base/location.h" |
| 16 #include "base/memory/ref_counted.h" | 16 #include "base/memory/ref_counted.h" |
| 17 #include "base/memory/scoped_ptr.h" | 17 #include "base/memory/scoped_ptr.h" |
| 18 #include "base/message_loop/incoming_task_queue.h" | 18 #include "base/message_loop/incoming_task_queue.h" |
| 19 #include "base/message_loop/message_loop_proxy.h" | 19 #include "base/message_loop/message_loop_task_runner.h" |
| 20 #include "base/message_loop/message_loop_proxy_impl.h" | |
| 21 #include "base/message_loop/message_pump.h" | 20 #include "base/message_loop/message_pump.h" |
| 22 #include "base/message_loop/timer_slack.h" | 21 #include "base/message_loop/timer_slack.h" |
| 23 #include "base/observer_list.h" | 22 #include "base/observer_list.h" |
| 24 #include "base/pending_task.h" | 23 #include "base/pending_task.h" |
| 25 #include "base/sequenced_task_runner_helpers.h" | 24 #include "base/sequenced_task_runner_helpers.h" |
| 26 #include "base/synchronization/lock.h" | 25 #include "base/synchronization/lock.h" |
| 27 #include "base/time/time.h" | 26 #include "base/time/time.h" |
| 28 #include "base/tracking_info.h" | 27 #include "base/tracking_info.h" |
| 29 | 28 |
| 30 // TODO(sky): these includes should not be necessary. Nuke them. | 29 // TODO(sky): these includes should not be necessary. Nuke them. |
| (...skipping 258 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 289 // Returns the type passed to the constructor. | 288 // Returns the type passed to the constructor. |
| 290 Type type() const { return type_; } | 289 Type type() const { return type_; } |
| 291 | 290 |
| 292 // Optional call to connect the thread name with this loop. | 291 // Optional call to connect the thread name with this loop. |
| 293 void set_thread_name(const std::string& thread_name) { | 292 void set_thread_name(const std::string& thread_name) { |
| 294 DCHECK(thread_name_.empty()) << "Should not rename this thread!"; | 293 DCHECK(thread_name_.empty()) << "Should not rename this thread!"; |
| 295 thread_name_ = thread_name; | 294 thread_name_ = thread_name; |
| 296 } | 295 } |
| 297 const std::string& thread_name() const { return thread_name_; } | 296 const std::string& thread_name() const { return thread_name_; } |
| 298 | 297 |
| 299 // Gets the message loop proxy associated with this message loop. | |
| 300 // | |
| 301 // NOTE: Deprecated; prefer task_runner() and the TaskRunner interfaces | |
| 302 scoped_refptr<MessageLoopProxy> message_loop_proxy() { | |
| 303 return message_loop_proxy_; | |
| 304 } | |
| 305 | |
| 306 // Gets the TaskRunner associated with this message loop. | 298 // Gets the TaskRunner associated with this message loop. |
| 307 // TODO(skyostil): Change this to return a const reference to a refptr | 299 // TODO(skyostil): Change this to return a const reference to a refptr |
| 308 // once the internal type matches what is being returned (crbug.com/465354). | 300 // once the internal type matches what is being returned (crbug.com/465354). |
| 309 scoped_refptr<SingleThreadTaskRunner> task_runner() { | 301 scoped_refptr<SingleThreadTaskRunner> task_runner() { return task_runner_; } |
| 310 return message_loop_proxy_; | |
| 311 } | |
| 312 | 302 |
| 313 // Enables or disables the recursive task processing. This happens in the case | 303 // Enables or disables the recursive task processing. This happens in the case |
| 314 // of recursive message loops. Some unwanted message loop may occurs when | 304 // of recursive message loops. Some unwanted message loop may occurs when |
| 315 // using common controls or printer functions. By default, recursive task | 305 // using common controls or printer functions. By default, recursive task |
| 316 // processing is disabled. | 306 // processing is disabled. |
| 317 // | 307 // |
| 318 // Please utilize |ScopedNestableTaskAllower| instead of calling these methods | 308 // Please utilize |ScopedNestableTaskAllower| instead of calling these methods |
| 319 // directly. In general nestable message loops are to be avoided. They are | 309 // directly. In general nestable message loops are to be avoided. They are |
| 320 // dangerous and difficult to get right, so please use with extreme caution. | 310 // dangerous and difficult to get right, so please use with extreme caution. |
| 321 // | 311 // |
| (...skipping 203 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 525 HistogramBase* message_histogram_; | 515 HistogramBase* message_histogram_; |
| 526 | 516 |
| 527 RunLoop* run_loop_; | 517 RunLoop* run_loop_; |
| 528 | 518 |
| 529 ObserverList<TaskObserver> task_observers_; | 519 ObserverList<TaskObserver> task_observers_; |
| 530 | 520 |
| 531 debug::TaskAnnotator task_annotator_; | 521 debug::TaskAnnotator task_annotator_; |
| 532 | 522 |
| 533 scoped_refptr<internal::IncomingTaskQueue> incoming_task_queue_; | 523 scoped_refptr<internal::IncomingTaskQueue> incoming_task_queue_; |
| 534 | 524 |
| 535 // The message loop proxy associated with this message loop. | 525 // The task runner associated with this message loop. |
| 536 scoped_refptr<internal::MessageLoopProxyImpl> message_loop_proxy_; | 526 scoped_refptr<internal::MessageLoopTaskRunner> task_runner_; |
| 537 scoped_ptr<ThreadTaskRunnerHandle> thread_task_runner_handle_; | 527 scoped_ptr<ThreadTaskRunnerHandle> thread_task_runner_handle_; |
| 538 | 528 |
| 539 template <class T, class R> friend class base::subtle::DeleteHelperInternal; | 529 template <class T, class R> friend class base::subtle::DeleteHelperInternal; |
| 540 template <class T, class R> friend class base::subtle::ReleaseHelperInternal; | 530 template <class T, class R> friend class base::subtle::ReleaseHelperInternal; |
| 541 | 531 |
| 542 void DeleteSoonInternal(const tracked_objects::Location& from_here, | 532 void DeleteSoonInternal(const tracked_objects::Location& from_here, |
| 543 void(*deleter)(const void*), | 533 void(*deleter)(const void*), |
| 544 const void* object); | 534 const void* object); |
| 545 void ReleaseSoonInternal(const tracked_objects::Location& from_here, | 535 void ReleaseSoonInternal(const tracked_objects::Location& from_here, |
| 546 void(*releaser)(const void*), | 536 void(*releaser)(const void*), |
| (...skipping 137 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 684 | 674 |
| 685 // Do not add any member variables to MessageLoopForIO! This is important b/c | 675 // Do not add any member variables to MessageLoopForIO! This is important b/c |
| 686 // MessageLoopForIO is often allocated via MessageLoop(TYPE_IO). Any extra | 676 // MessageLoopForIO is often allocated via MessageLoop(TYPE_IO). Any extra |
| 687 // data that you need should be stored on the MessageLoop's pump_ instance. | 677 // data that you need should be stored on the MessageLoop's pump_ instance. |
| 688 COMPILE_ASSERT(sizeof(MessageLoop) == sizeof(MessageLoopForIO), | 678 COMPILE_ASSERT(sizeof(MessageLoop) == sizeof(MessageLoopForIO), |
| 689 MessageLoopForIO_should_not_have_extra_member_variables); | 679 MessageLoopForIO_should_not_have_extra_member_variables); |
| 690 | 680 |
| 691 } // namespace base | 681 } // namespace base |
| 692 | 682 |
| 693 #endif // BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ | 683 #endif // BASE_MESSAGE_LOOP_MESSAGE_LOOP_H_ |
| OLD | NEW |