OLD | NEW |
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 #ifndef RUNTIME_VM_OS_THREAD_WIN_H_ | 5 #ifndef RUNTIME_VM_OS_THREAD_WIN_H_ |
6 #define RUNTIME_VM_OS_THREAD_WIN_H_ | 6 #define RUNTIME_VM_OS_THREAD_WIN_H_ |
7 | 7 |
8 #if !defined(RUNTIME_VM_OS_THREAD_H_) | 8 #if !defined(RUNTIME_VM_OS_THREAD_H_) |
9 #error Do not include os_thread_win.h directly; use os_thread.h instead. | 9 #error Do not include os_thread_win.h directly; use os_thread.h instead. |
10 #endif | 10 #endif |
11 | 11 |
12 #include "platform/assert.h" | 12 #include "platform/assert.h" |
13 #include "platform/globals.h" | 13 #include "platform/globals.h" |
14 | 14 |
15 #include "vm/allocation.h" | 15 #include "vm/allocation.h" |
16 | 16 |
17 namespace dart { | 17 namespace dart { |
18 | 18 |
19 typedef DWORD ThreadLocalKey; | 19 typedef DWORD ThreadLocalKey; |
20 typedef DWORD ThreadId; | 20 typedef DWORD ThreadId; |
21 typedef HANDLE ThreadJoinId; | 21 typedef HANDLE ThreadJoinId; |
22 | 22 |
23 | |
24 static const ThreadLocalKey kUnsetThreadLocalKey = TLS_OUT_OF_INDEXES; | 23 static const ThreadLocalKey kUnsetThreadLocalKey = TLS_OUT_OF_INDEXES; |
25 | 24 |
26 | |
27 class ThreadInlineImpl { | 25 class ThreadInlineImpl { |
28 private: | 26 private: |
29 ThreadInlineImpl() {} | 27 ThreadInlineImpl() {} |
30 ~ThreadInlineImpl() {} | 28 ~ThreadInlineImpl() {} |
31 | 29 |
32 static uword GetThreadLocal(ThreadLocalKey key) { | 30 static uword GetThreadLocal(ThreadLocalKey key) { |
33 ASSERT(key != kUnsetThreadLocalKey); | 31 ASSERT(key != kUnsetThreadLocalKey); |
34 return reinterpret_cast<uword>(TlsGetValue(key)); | 32 return reinterpret_cast<uword>(TlsGetValue(key)); |
35 } | 33 } |
36 | 34 |
37 friend class OSThread; | 35 friend class OSThread; |
38 friend unsigned int __stdcall ThreadEntry(void* data_ptr); | 36 friend unsigned int __stdcall ThreadEntry(void* data_ptr); |
39 | 37 |
40 DISALLOW_ALLOCATION(); | 38 DISALLOW_ALLOCATION(); |
41 DISALLOW_COPY_AND_ASSIGN(ThreadInlineImpl); | 39 DISALLOW_COPY_AND_ASSIGN(ThreadInlineImpl); |
42 }; | 40 }; |
43 | 41 |
44 | |
45 class MutexData { | 42 class MutexData { |
46 private: | 43 private: |
47 MutexData() {} | 44 MutexData() {} |
48 ~MutexData() {} | 45 ~MutexData() {} |
49 | 46 |
50 HANDLE semaphore_; | 47 HANDLE semaphore_; |
51 | 48 |
52 friend class Mutex; | 49 friend class Mutex; |
53 | 50 |
54 DISALLOW_ALLOCATION(); | 51 DISALLOW_ALLOCATION(); |
55 DISALLOW_COPY_AND_ASSIGN(MutexData); | 52 DISALLOW_COPY_AND_ASSIGN(MutexData); |
56 }; | 53 }; |
57 | 54 |
58 | |
59 class MonitorWaitData { | 55 class MonitorWaitData { |
60 public: | 56 public: |
61 static void ThreadExit(); | 57 static void ThreadExit(); |
62 | 58 |
63 private: | 59 private: |
64 explicit MonitorWaitData(HANDLE event) : event_(event), next_(NULL) {} | 60 explicit MonitorWaitData(HANDLE event) : event_(event), next_(NULL) {} |
65 ~MonitorWaitData() { | 61 ~MonitorWaitData() { |
66 CloseHandle(event_); | 62 CloseHandle(event_); |
67 ASSERT(next_ == NULL); | 63 ASSERT(next_ == NULL); |
68 } | 64 } |
69 | 65 |
70 // ThreadLocalKey used to fetch and store the MonitorWaitData object | 66 // ThreadLocalKey used to fetch and store the MonitorWaitData object |
71 // for a given thread. | 67 // for a given thread. |
72 static ThreadLocalKey monitor_wait_data_key_; | 68 static ThreadLocalKey monitor_wait_data_key_; |
73 | 69 |
74 // Auto-reset event used for waiting. | 70 // Auto-reset event used for waiting. |
75 HANDLE event_; | 71 HANDLE event_; |
76 // Link to next element in the singly-linked list of waiters. | 72 // Link to next element in the singly-linked list of waiters. |
77 MonitorWaitData* next_; | 73 MonitorWaitData* next_; |
78 | 74 |
79 friend class Monitor; | 75 friend class Monitor; |
80 friend class MonitorData; | 76 friend class MonitorData; |
81 friend class OS; | 77 friend class OS; |
82 | 78 |
83 | |
84 DISALLOW_COPY_AND_ASSIGN(MonitorWaitData); | 79 DISALLOW_COPY_AND_ASSIGN(MonitorWaitData); |
85 }; | 80 }; |
86 | 81 |
87 | |
88 class MonitorData { | 82 class MonitorData { |
89 private: | 83 private: |
90 MonitorData() {} | 84 MonitorData() {} |
91 ~MonitorData() {} | 85 ~MonitorData() {} |
92 | 86 |
93 // Helper methods to manipulate the list of waiters for this | 87 // Helper methods to manipulate the list of waiters for this |
94 // monitor. | 88 // monitor. |
95 void AddWaiter(MonitorWaitData* wait_data); | 89 void AddWaiter(MonitorWaitData* wait_data); |
96 void RemoveWaiter(MonitorWaitData* wait_data); | 90 void RemoveWaiter(MonitorWaitData* wait_data); |
97 void SignalAndRemoveFirstWaiter(); | 91 void SignalAndRemoveFirstWaiter(); |
(...skipping 16 matching lines...) Expand all Loading... |
114 MonitorWaitData* waiters_tail_; | 108 MonitorWaitData* waiters_tail_; |
115 | 109 |
116 friend class Monitor; | 110 friend class Monitor; |
117 friend class OS; | 111 friend class OS; |
118 friend unsigned int __stdcall ThreadEntry(void* data_ptr); | 112 friend unsigned int __stdcall ThreadEntry(void* data_ptr); |
119 | 113 |
120 DISALLOW_ALLOCATION(); | 114 DISALLOW_ALLOCATION(); |
121 DISALLOW_COPY_AND_ASSIGN(MonitorData); | 115 DISALLOW_COPY_AND_ASSIGN(MonitorData); |
122 }; | 116 }; |
123 | 117 |
124 | |
125 typedef void (*ThreadDestructor)(void* parameter); | 118 typedef void (*ThreadDestructor)(void* parameter); |
126 | 119 |
127 | |
128 class ThreadLocalEntry { | 120 class ThreadLocalEntry { |
129 public: | 121 public: |
130 ThreadLocalEntry(ThreadLocalKey key, ThreadDestructor destructor) | 122 ThreadLocalEntry(ThreadLocalKey key, ThreadDestructor destructor) |
131 : key_(key), destructor_(destructor) {} | 123 : key_(key), destructor_(destructor) {} |
132 | 124 |
133 ThreadLocalKey key() const { return key_; } | 125 ThreadLocalKey key() const { return key_; } |
134 | 126 |
135 | |
136 ThreadDestructor destructor() const { return destructor_; } | 127 ThreadDestructor destructor() const { return destructor_; } |
137 | 128 |
138 private: | 129 private: |
139 ThreadLocalKey key_; | 130 ThreadLocalKey key_; |
140 ThreadDestructor destructor_; | 131 ThreadDestructor destructor_; |
141 | 132 |
142 DISALLOW_ALLOCATION(); | 133 DISALLOW_ALLOCATION(); |
143 }; | 134 }; |
144 | 135 |
145 | |
146 template <typename T> | 136 template <typename T> |
147 class MallocGrowableArray; | 137 class MallocGrowableArray; |
148 | 138 |
149 | |
150 class ThreadLocalData : public AllStatic { | 139 class ThreadLocalData : public AllStatic { |
151 public: | 140 public: |
152 static void RunDestructors(); | 141 static void RunDestructors(); |
153 | 142 |
154 private: | 143 private: |
155 static void AddThreadLocal(ThreadLocalKey key, ThreadDestructor destructor); | 144 static void AddThreadLocal(ThreadLocalKey key, ThreadDestructor destructor); |
156 static void RemoveThreadLocal(ThreadLocalKey key); | 145 static void RemoveThreadLocal(ThreadLocalKey key); |
157 | 146 |
158 static Mutex* mutex_; | 147 static Mutex* mutex_; |
159 static MallocGrowableArray<ThreadLocalEntry>* thread_locals_; | 148 static MallocGrowableArray<ThreadLocalEntry>* thread_locals_; |
160 | 149 |
161 static void InitOnce(); | 150 static void InitOnce(); |
162 static void Shutdown(); | 151 static void Shutdown(); |
163 | 152 |
164 friend class OS; | 153 friend class OS; |
165 friend class OSThread; | 154 friend class OSThread; |
166 }; | 155 }; |
167 | 156 |
168 } // namespace dart | 157 } // namespace dart |
169 | 158 |
170 #endif // RUNTIME_VM_OS_THREAD_WIN_H_ | 159 #endif // RUNTIME_VM_OS_THREAD_WIN_H_ |
OLD | NEW |