Uses an open thread handle as the ThreadJoinId on Windows.

runtime/bin/eventhandler_win.cc

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 #if !defined(DART_IO_DISABLED)
 
 #include "platform/globals.h"
 #if defined(TARGET_OS_WINDOWS)
 
 #include "bin/eventhandler.h"
@@ skipping 170 matching lines @@
 
 void Handle::WaitForReadThreadStarted() {
   MonitorLocker ml(monitor_);
   while (read_thread_starting_) {
     ml.Wait();
   }
 }
 
 
 void Handle::WaitForReadThreadFinished() {
-  // Join the Reader thread if there is one.
-  ThreadId to_join = Thread::kInvalidThreadId;
-  {
-    MonitorLocker ml(monitor_);
-    if (read_thread_id_ != Thread::kInvalidThreadId) {
-      while (!read_thread_finished_) {
-        ml.Wait();
-      }
-      read_thread_finished_ = false;
-      to_join = read_thread_id_;
-      read_thread_id_ = Thread::kInvalidThreadId;
+  MonitorLocker ml(monitor_);
+  if (read_thread_id_ != Thread::kInvalidThreadId) {
+    while (!read_thread_finished_) {
+      ml.Wait();
     }
-  }
-  if (to_join != Thread::kInvalidThreadId) {
-    Thread::Join(to_join);
+    read_thread_finished_ = false;
+    read_thread_id_ = Thread::kInvalidThreadId;
   }
 }
 
 
 void Handle::ReadComplete(OverlappedBuffer* buffer) {
   WaitForReadThreadStarted();
   {
     MonitorLocker ml(monitor_);
     // Currently only one outstanding read at the time.
     ASSERT(pending_read_ == buffer);
@@ skipping 616 matching lines @@
 
 
 void StdHandle::DoClose() {
   MonitorLocker ml(monitor_);
   if (write_thread_exists_) {
     write_thread_running_ = false;
     ml.Notify();
     while (write_thread_exists_) {
       ml.Wait(Monitor::kNoTimeout);
     }
-    Thread::Join(thread_id_);
   }
   Handle::DoClose();
 }
 
 
 bool ClientSocket::LoadDisconnectEx() {
   // Load the DisconnectEx function into memory using WSAIoctl.
   GUID guid_disconnect_ex = WSAID_DISCONNECTEX;
   DWORD bytes;
   int status = WSAIoctl(socket(),
@@ skipping 516 matching lines @@
   completion_port_ =
       CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, NULL, 1);
   if (completion_port_ == NULL) {
     FATAL("Completion port creation failed");
   }
   shutdown_ = false;
 }
 
 
 EventHandlerImplementation::~EventHandlerImplementation() {
-  Thread::Join(handler_thread_id_);
   delete startup_monitor_;
   CloseHandle(completion_port_);
 }
 
 
 int64_t EventHandlerImplementation::GetTimeout() {
   if (!timeout_queue_.HasTimeout()) {
     return kInfinityTimeout;
   }
   int64_t millis = timeout_queue_.CurrentTimeout() -
@@ skipping 112 matching lines @@
 void EventHandlerImplementation::Shutdown() {
   SendData(kShutdownId, 0, 0);
 }
 
 }  // namespace bin
 }  // namespace dart
 
 #endif  // defined(TARGET_OS_WINDOWS)
 
 #endif  // !defined(DART_IO_DISABLED)