Blink roll 25b6bd3a7a131ffe68d809546ad1a20707915cdc:3a503f41ae42e5b79cfcd2ff10e65afde...
[chromium-blink-merge.git] / base / message_loop / message_loop_proxy_impl.h
blob0fe629f9d140c0244128e49598308a9a48d15366
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
3 // found in the LICENSE file.
5 #ifndef BASE_MESSAGE_LOOP_MESSAGE_LOOP_PROXY_IMPL_H_
6 #define BASE_MESSAGE_LOOP_MESSAGE_LOOP_PROXY_IMPL_H_
8 #include "base/base_export.h"
9 #include "base/memory/ref_counted.h"
10 #include "base/message_loop/message_loop_proxy.h"
11 #include "base/pending_task.h"
12 #include "base/threading/platform_thread.h"
14 namespace base {
15 namespace internal {
17 class IncomingTaskQueue;
19 // A stock implementation of MessageLoopProxy that is created and managed by a
20 // MessageLoop. For now a MessageLoopProxyImpl can only be created as part of a
21 // MessageLoop.
22 class BASE_EXPORT MessageLoopProxyImpl : public MessageLoopProxy {
23 public:
24 explicit MessageLoopProxyImpl(
25 scoped_refptr<IncomingTaskQueue> incoming_queue);
27 // MessageLoopProxy implementation
28 bool PostDelayedTask(const tracked_objects::Location& from_here,
29 const base::Closure& task,
30 base::TimeDelta delay) override;
31 bool PostNonNestableDelayedTask(const tracked_objects::Location& from_here,
32 const base::Closure& task,
33 base::TimeDelta delay) override;
34 bool RunsTasksOnCurrentThread() const override;
36 private:
37 friend class RefCountedThreadSafe<MessageLoopProxyImpl>;
38 ~MessageLoopProxyImpl() override;
40 // THe incoming queue receiving all posted tasks.
41 scoped_refptr<IncomingTaskQueue> incoming_queue_;
43 // ID of the thread |this| was created on.
44 PlatformThreadId valid_thread_id_;
46 DISALLOW_COPY_AND_ASSIGN(MessageLoopProxyImpl);
49 } // namespace internal
50 } // namespace base
52 #endif // BASE_MESSAGE_LOOP_MESSAGE_LOOP_PROXY_IMPL_H_