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 // WARNING: You should *NOT* be using this class directly. PlatformThread is
6 // the low-level platform-specific abstraction to the OS's threading interface.
7 // You should instead be using a message-loop driven Thread, see thread.h.
9 #ifndef BASE_THREADING_PLATFORM_THREAD_H_
10 #define BASE_THREADING_PLATFORM_THREAD_H_
12 #include "base/base_export.h"
13 #include "base/basictypes.h"
14 #include "base/time/time.h"
15 #include "build/build_config.h"
19 #elif defined(OS_POSIX)
26 // Used for logging. Always an integer value.
28 typedef DWORD PlatformThreadId
;
29 #elif defined(OS_POSIX)
30 typedef pid_t PlatformThreadId
;
33 // Used for thread checking and debugging.
34 // Meant to be as fast as possible.
35 // These are produced by PlatformThread::CurrentRef(), and used to later
36 // check if we are on the same thread or not by using ==. These are safe
37 // to copy between threads, but can't be copied to another process as they
38 // have no meaning there. Also, the internal identifier can be re-used
39 // after a thread dies, so a PlatformThreadRef cannot be reliably used
40 // to distinguish a new thread from an old, dead thread.
41 class PlatformThreadRef
{
44 typedef DWORD RefType
;
45 #elif defined(OS_POSIX)
46 typedef pthread_t RefType
;
52 explicit PlatformThreadRef(RefType id
)
56 bool operator==(PlatformThreadRef other
) const {
57 return id_
== other
.id_
;
60 bool is_null() const {
67 // Used to operate on threads.
68 class PlatformThreadHandle
{
72 #elif defined(OS_POSIX)
73 typedef pthread_t Handle
;
76 PlatformThreadHandle()
81 explicit PlatformThreadHandle(Handle handle
)
86 PlatformThreadHandle(Handle handle
,
92 PlatformThreadId
id() const {
96 bool is_equal(const PlatformThreadHandle
& other
) const {
97 return handle_
== other
.handle_
;
100 bool is_null() const {
104 Handle
platform_handle() const {
110 PlatformThreadId id_
;
113 const PlatformThreadId
kInvalidThreadId(0);
115 // Valid values for SetThreadPriority(), listed in increasing order of
117 enum class ThreadPriority
{
118 // Suitable for threads that shouldn't disrupt high priority work.
120 // Default priority level.
122 // Suitable for threads which generate data for the display (at ~60Hz).
124 // Suitable for low-latency, glitch-resistant audio.
128 // A namespace for low-level thread functions.
129 class BASE_EXPORT PlatformThread
{
131 // Implement this interface to run code on a background thread. Your
132 // ThreadMain method will be called on the newly created thread.
133 class BASE_EXPORT Delegate
{
135 virtual void ThreadMain() = 0;
138 virtual ~Delegate() {}
141 // Gets the current thread id, which may be useful for logging purposes.
142 static PlatformThreadId
CurrentId();
144 // Gets the current thread reference, which can be used to check if
145 // we're on the right thread quickly.
146 static PlatformThreadRef
CurrentRef();
148 // Get the handle representing the current thread. On Windows, this is a
149 // pseudo handle constant which will always represent the thread using it and
150 // hence should not be shared with other threads nor be used to differentiate
151 // the current thread from another.
152 static PlatformThreadHandle
CurrentHandle();
154 // Yield the current thread so another thread can be scheduled.
155 static void YieldCurrentThread();
157 // Sleeps for the specified duration.
158 static void Sleep(base::TimeDelta duration
);
160 // Sets the thread name visible to debuggers/tools. This has no effect
162 static void SetName(const std::string
& name
);
164 // Gets the thread name, if previously set by SetName.
165 static const char* GetName();
167 // Creates a new thread. The |stack_size| parameter can be 0 to indicate
168 // that the default stack size should be used. Upon success,
169 // |*thread_handle| will be assigned a handle to the newly created thread,
170 // and |delegate|'s ThreadMain method will be executed on the newly created
172 // NOTE: When you are done with the thread handle, you must call Join to
173 // release system resources associated with the thread. You must ensure that
174 // the Delegate object outlives the thread.
175 static bool Create(size_t stack_size
, Delegate
* delegate
,
176 PlatformThreadHandle
* thread_handle
);
178 // CreateWithPriority() does the same thing as Create() except the priority of
179 // the thread is set based on |priority|. Can be used in place of Create()
180 // followed by SetThreadPriority().
181 static bool CreateWithPriority(size_t stack_size
, Delegate
* delegate
,
182 PlatformThreadHandle
* thread_handle
,
183 ThreadPriority priority
);
185 // CreateNonJoinable() does the same thing as Create() except the thread
186 // cannot be Join()'d. Therefore, it also does not output a
187 // PlatformThreadHandle.
188 static bool CreateNonJoinable(size_t stack_size
, Delegate
* delegate
);
190 // Joins with a thread created via the Create function. This function blocks
191 // the caller until the designated thread exits. This will invalidate
193 static void Join(PlatformThreadHandle thread_handle
);
195 // Toggles the target thread's priority at runtime. Prefer
196 // CreateWithPriority() to set the thread's initial priority.
197 // NOTE: The call may fail if the caller thread is not the same as the
198 // target thread on POSIX. For example, seccomp-bpf blocks it by default
200 static void SetThreadPriority(PlatformThreadHandle handle
,
201 ThreadPriority priority
);
203 static ThreadPriority
GetThreadPriority(PlatformThreadHandle handle
);
206 DISALLOW_IMPLICIT_CONSTRUCTORS(PlatformThread
);
211 #endif // BASE_THREADING_PLATFORM_THREAD_H_