Change the thread interface in runtime/platform and use it starting all threads

runtime/bin/thread_pool.cc

 // Copyright (c) 2012, 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.
 
 #include "bin/thread_pool.h"
 
 #include "bin/thread.h"
 
 void TaskQueue::Insert(TaskQueueEntry* entry) {
   MonitorLocker monitor(&monitor_);
@@ skipping 45 matching lines @@
   TaskQueueEntry* entry = queue_.Remove();
   if (entry == NULL) {
     return NULL;
   }
   Task task = entry->task();
   delete entry;
   return task;
 }
 
 
-void* ThreadPool::Main(void* args) {
+void ThreadPool::Start() {
+  MonitorLocker monitor(&monitor_);

[Ivan Posva, 2012/02/02 07:53:24]

It is very, very confusing to have two different MonitorLocker classes!

[Søren Gjesse, 2012/02/02 08:46:08]

They are in different namespaces though. I will try to come up with two
different names though.

+  for (int i = 0; i < size_; i++) {
+    int result = dart::Thread::Start(&ThreadPool::Main,
+                                     reinterpret_cast<uword>(this));
+    if (result != 0) {
+      FATAL1("Failed to start thread pool thread %d", result);
+    }
+  }
+}
+
+
+void ThreadPool::Shutdown() {
+  terminate_ = true;
+  queue_.Shutdown();
+  MonitorLocker monitor(&monitor_);
+  while (size_ > 0) {
+    monitor.Wait();
+  }
+}
+
+
+void ThreadPool::ThreadTerminated() {
+  MonitorLocker monitor(&monitor_);
+  size_--;
+  monitor.Notify();
+}
+
+
+void ThreadPool::Main(uword args) {
   if (Dart_IsVMFlagSet("trace_thread_pool")) {
     printf("Thread pool thread started\n");
   }
   ThreadPool* pool = reinterpret_cast<ThreadPool*>(args);
   while (!pool->terminate_) {
     if (Dart_IsVMFlagSet("trace_thread_pool")) {
       printf("Waiting for task\n");
     }
     Task task = pool->WaitForTask();
-    if (pool->terminate_) return NULL;
+    if (pool->terminate_) break;
     (*(pool->task_handler_))(task);
   }
-  return NULL;
+  pool->ThreadTerminated();
 };