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 PLATFORM_THREAD_WIN_H_ | 5 #ifndef PLATFORM_THREAD_WIN_H_ |
6 #define PLATFORM_THREAD_WIN_H_ | 6 #define PLATFORM_THREAD_WIN_H_ |
7 | 7 |
8 #if !defined(PLATFORM_THREAD_H_) | 8 #if !defined(PLATFORM_THREAD_H_) |
9 #error Do not include thread_win.h directly; use thread.h instead. | 9 #error Do not include thread_win.h directly; use 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 namespace dart { | 15 namespace dart { |
16 | 16 |
17 typedef DWORD ThreadLocalKey; | 17 typedef DWORD ThreadLocalKey; |
| 18 typedef HANDLE ThreadId; |
| 19 |
18 | 20 |
19 class ThreadInlineImpl { | 21 class ThreadInlineImpl { |
20 private: | 22 private: |
21 ThreadInlineImpl() {} | 23 ThreadInlineImpl() {} |
22 ~ThreadInlineImpl() {} | 24 ~ThreadInlineImpl() {} |
23 | 25 |
| 26 static ThreadLocalKey thread_id_key; |
| 27 static ThreadId CreateThreadId(); |
| 28 static void DestroyThreadId(ThreadId); |
24 static uword GetThreadLocal(ThreadLocalKey key) { | 29 static uword GetThreadLocal(ThreadLocalKey key) { |
25 static ThreadLocalKey kUnsetThreadLocalKey = TLS_OUT_OF_INDEXES; | 30 static ThreadLocalKey kUnsetThreadLocalKey = TLS_OUT_OF_INDEXES; |
26 ASSERT(key != kUnsetThreadLocalKey); | 31 ASSERT(key != kUnsetThreadLocalKey); |
27 return reinterpret_cast<uword>(TlsGetValue(key)); | 32 return reinterpret_cast<uword>(TlsGetValue(key)); |
28 } | 33 } |
29 | 34 |
30 friend class Thread; | 35 friend class Thread; |
| 36 friend class OS; |
| 37 friend unsigned int __stdcall ThreadEntry(void* data_ptr); |
31 | 38 |
32 DISALLOW_ALLOCATION(); | 39 DISALLOW_ALLOCATION(); |
33 DISALLOW_COPY_AND_ASSIGN(ThreadInlineImpl); | 40 DISALLOW_COPY_AND_ASSIGN(ThreadInlineImpl); |
34 }; | 41 }; |
35 | 42 |
36 | 43 |
37 class MutexData { | 44 class MutexData { |
38 private: | 45 private: |
39 MutexData() {} | 46 MutexData() {} |
40 ~MutexData() {} | 47 ~MutexData() {} |
(...skipping 22 matching lines...) Expand all Loading... |
63 // for a given thread. | 70 // for a given thread. |
64 static ThreadLocalKey monitor_wait_data_key_; | 71 static ThreadLocalKey monitor_wait_data_key_; |
65 | 72 |
66 // Auto-reset event used for waiting. | 73 // Auto-reset event used for waiting. |
67 HANDLE event_; | 74 HANDLE event_; |
68 // Link to next element in the singly-linked list of waiters. | 75 // Link to next element in the singly-linked list of waiters. |
69 MonitorWaitData* next_; | 76 MonitorWaitData* next_; |
70 | 77 |
71 friend class Monitor; | 78 friend class Monitor; |
72 friend class MonitorData; | 79 friend class MonitorData; |
| 80 friend class OS; |
| 81 |
73 | 82 |
74 DISALLOW_COPY_AND_ASSIGN(MonitorWaitData); | 83 DISALLOW_COPY_AND_ASSIGN(MonitorWaitData); |
75 }; | 84 }; |
76 | 85 |
77 | 86 |
78 class MonitorData { | 87 class MonitorData { |
79 private: | 88 private: |
80 MonitorData() {} | 89 MonitorData() {} |
81 ~MonitorData() {} | 90 ~MonitorData() {} |
82 | 91 |
83 // Helper methods to manipulate the list of waiters for this | 92 // Helper methods to manipulate the list of waiters for this |
84 // monitor. | 93 // monitor. |
85 void AddWaiter(MonitorWaitData* wait_data); | 94 void AddWaiter(MonitorWaitData* wait_data); |
86 void RemoveWaiter(MonitorWaitData* wait_data); | 95 void RemoveWaiter(MonitorWaitData* wait_data); |
87 void SignalAndRemoveFirstWaiter(); | 96 void SignalAndRemoveFirstWaiter(); |
88 void SignalAndRemoveAllWaiters(); | 97 void SignalAndRemoveAllWaiters(); |
89 MonitorWaitData* GetMonitorWaitDataForThread(); | 98 static MonitorWaitData* GetMonitorWaitDataForThread(); |
90 | 99 |
91 // The external critical section for the monitor. | 100 // The external critical section for the monitor. |
92 CRITICAL_SECTION cs_; | 101 CRITICAL_SECTION cs_; |
93 | 102 |
94 // Condition variables are only available since Windows Vista. To | 103 // Condition variables are only available since Windows Vista. To |
95 // support at least Windows XP, we implement our own condition | 104 // support at least Windows XP, we implement our own condition |
96 // variables using SetEvent on Event objects. | 105 // variables using SetEvent on Event objects. |
97 | 106 |
98 // Singly-linked list of event objects, one for each thread waiting | 107 // Singly-linked list of event objects, one for each thread waiting |
99 // on this monitor. New waiters are added at the end of the list. | 108 // on this monitor. New waiters are added at the end of the list. |
100 // Notify signals the first element of the list (FIFO | 109 // Notify signals the first element of the list (FIFO |
101 // order). NotifyAll, signals all the elements of the list. | 110 // order). NotifyAll, signals all the elements of the list. |
102 CRITICAL_SECTION waiters_cs_; | 111 CRITICAL_SECTION waiters_cs_; |
103 MonitorWaitData* waiters_head_; | 112 MonitorWaitData* waiters_head_; |
104 MonitorWaitData* waiters_tail_; | 113 MonitorWaitData* waiters_tail_; |
105 | 114 |
106 friend class Monitor; | 115 friend class Monitor; |
| 116 friend class OS; |
| 117 friend unsigned int __stdcall ThreadEntry(void* data_ptr); |
107 | 118 |
108 DISALLOW_ALLOCATION(); | 119 DISALLOW_ALLOCATION(); |
109 DISALLOW_COPY_AND_ASSIGN(MonitorData); | 120 DISALLOW_COPY_AND_ASSIGN(MonitorData); |
110 }; | 121 }; |
111 | 122 |
112 } // namespace dart | 123 } // namespace dart |
113 | 124 |
114 #endif // PLATFORM_THREAD_WIN_H_ | 125 #endif // PLATFORM_THREAD_WIN_H_ |
OLD | NEW |