Index: runtime/platform/thread_win.cc |
diff --git a/runtime/vm/thread_win.cc b/runtime/platform/thread_win.cc |
similarity index 60% |
copy from runtime/vm/thread_win.cc |
copy to runtime/platform/thread_win.cc |
index c763babd4de6ef9801e9231d26868ef537a483f6..048b2cc3590d059f4925986b680d92fa535f2443 100644 |
--- a/runtime/vm/thread_win.cc |
+++ b/runtime/platform/thread_win.cc |
@@ -5,68 +5,10 @@ |
#include <process.h> |
#include "platform/assert.h" |
-#include "vm/thread.h" |
+#include "platform/thread.h" |
namespace dart { |
-class ThreadStartData { |
- public: |
- ThreadStartData(Thread::ThreadStartFunction function, |
- uword parameter, |
- Thread* thread) |
- : function_(function), parameter_(parameter), thread_(thread) {} |
- |
- Thread::ThreadStartFunction function() const { return function_; } |
- uword parameter() const { return parameter_; } |
- Thread* thread() const { return thread_; } |
- |
- private: |
- Thread::ThreadStartFunction function_; |
- uword parameter_; |
- Thread* thread_; |
- |
- DISALLOW_COPY_AND_ASSIGN(ThreadStartData); |
-}; |
- |
- |
-// Dispatch to the thread start function provided by the caller. This trampoline |
-// is used to ensure that the thread is properly destroyed if the thread just |
-// exits. |
-static unsigned int __stdcall ThreadEntry(void* data_ptr) { |
- ThreadStartData* data = reinterpret_cast<ThreadStartData*>(data_ptr); |
- |
- Thread::ThreadStartFunction function = data->function(); |
- uword parameter = data->parameter(); |
- Thread* thread = data->thread(); |
- delete data; |
- |
- // Call the supplied thread start function handing it its parameters. |
- function(parameter); |
- |
- // When the function returns here, make sure that the thread is deleted. |
- delete thread; |
- |
- return 0; |
-} |
- |
- |
-Thread::Thread(ThreadStartFunction function, uword parameter) { |
- ThreadStartData* start_data = new ThreadStartData(function, parameter, this); |
- uint32_t tid; |
- data_.thread_handle_ = |
- _beginthreadex(NULL, 64 * KB, ThreadEntry, start_data, 0, &tid); |
- if (data_.thread_handle_ == -1) { |
- FATAL("Thread creation failed"); |
- } |
- data_.tid_ = tid; |
-} |
- |
- |
-Thread::~Thread() { |
- CloseHandle(reinterpret_cast<HANDLE>(data_.thread_handle_)); |
-} |
- |
- |
Mutex::Mutex() { |
// Allocate unnamed semaphore with initial count 1 and max count 1. |
data_.semaphore_ = CreateSemaphore(NULL, 1, 1, NULL); |