Start isolates in a separate thread.

runtime/lib/isolate.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 "include/dart_native_api.h"
 #include "platform/assert.h"
 #include "vm/bootstrap_natives.h"
 #include "vm/class_finalizer.h"
 #include "vm/dart.h"
 #include "vm/dart_api_impl.h"
 #include "vm/dart_entry.h"
 #include "vm/exceptions.h"
 #include "vm/lockers.h"
 #include "vm/longjump.h"
 #include "vm/message_handler.h"
@@ skipping 103 matching lines @@
 }
 
 
 static void ThrowIsolateSpawnException(const String& message) {
   const Array& args = Array::Handle(Array::New(1));
   args.SetAt(0, message);
   Exceptions::ThrowByType(Exceptions::kIsolateSpawn, args);
 }
 
 
-static bool CreateIsolate(Isolate* parent_isolate,
-                          IsolateSpawnState* state,
-                          char** error) {
-  Dart_IsolateCreateCallback callback = Isolate::CreateCallback();
-  if (callback == NULL) {
-    *error = strdup("Null callback specified for isolate creation\n");
-    return false;
+class SpawnIsolateTask : public ThreadPool::Task {
+ public:
+  explicit SpawnIsolateTask(IsolateSpawnState* state) : state_(state) {}
+
+  virtual void Run() {
+    // Create a new isolate.
+    char* error = NULL;
+    Dart_IsolateCreateCallback callback = Isolate::CreateCallback();
+    if (callback == NULL) {
+      ReportError(
+          "Isolate spawn is not supported by this Dart implementation\n");
+      delete state_;
+      state_ = NULL;
+      return;
+    }
+
+    Dart_IsolateFlags api_flags;
+    state_->isolate_flags()->CopyTo(&api_flags);
+
+    Isolate* isolate = reinterpret_cast<Isolate*>(
+        (callback)(state_->script_url(),
+                   state_->function_name(),
+                   state_->package_root(),
+                   state_->package_map(),
+                   &api_flags,
+                   state_->init_data(),
+                   &error));
+    if (isolate == NULL) {
+      ReportError(error);
+      delete state_;
+      state_ = NULL;
+      free(error);
+      return;
+    }
+
+    if (state_->origin_id() != ILLEGAL_PORT) {
+      // For isolates spawned using spawnFunction we set the origin_id
+      // to the origin_id of the parent isolate.
+      isolate->set_origin_id(state_->origin_id());
+    }
+    MutexLocker ml(isolate->mutex());
+    state_->set_isolate(reinterpret_cast<Isolate*>(isolate));
+    isolate->set_spawn_state(state_);
+    state_ = NULL;
+    if (isolate->is_runnable()) {
+      isolate->Run();
+    }
   }
 
-  Dart_IsolateFlags api_flags;
-  state->isolate_flags()->CopyTo(&api_flags);
+ private:
+  void ReportError(const char* error) {
+    Dart_CObject error_cobj;
+    error_cobj.type = Dart_CObject_kString;
+    error_cobj.value.as_string = const_cast<char*>(error);
+    if (!Dart_PostCObject(state_->parent_port(), &error_cobj)) {
+      // Perhaps the parent isolate died or closed the port before we
+      // could report the error.  Ignore.
+    }
+  }
 
-  void* init_data = parent_isolate->init_callback_data();
-  Isolate* child_isolate = reinterpret_cast<Isolate*>(
-      (callback)(state->script_url(),
-                 state->function_name(),
-                 state->package_root(),
-                 state->package_map(),
-                 &api_flags,
-                 init_data,
-                 error));
-  if (child_isolate == NULL) {
-    return false;
-  }
-  if (!state->is_spawn_uri()) {
-    // For isolates spawned using the spawn semantics we set
-    // the origin_id to the origin_id of the parent isolate.
-    child_isolate->set_origin_id(parent_isolate->origin_id());
-  }
-  state->set_isolate(reinterpret_cast<Isolate*>(child_isolate));
-  return true;
-}
+  IsolateSpawnState* state_;
 
-
-static void Spawn(Isolate* parent_isolate, IsolateSpawnState* state) {
-  Thread::ExitIsolate();
-  // Create a new isolate.
-  char* error = NULL;
-  if (!CreateIsolate(parent_isolate, state, &error)) {
-    Thread::EnterIsolate(parent_isolate);
-    delete state;
-    const String& msg = String::Handle(String::New(error));
-    free(error);
-    ThrowIsolateSpawnException(msg);
-  }
-  Thread::EnterIsolate(parent_isolate);
-  // Start the new isolate if it is already marked as runnable.
-  Isolate* spawned_isolate = state->isolate();
-  MutexLocker ml(spawned_isolate->mutex());
-  spawned_isolate->set_spawn_state(state);
-  if (spawned_isolate->is_runnable()) {
-    spawned_isolate->Run();
-  }
-}
+  DISALLOW_COPY_AND_ASSIGN(SpawnIsolateTask);
+};
 
 
 DEFINE_NATIVE_ENTRY(Isolate_spawnFunction, 7) {
   GET_NON_NULL_NATIVE_ARGUMENT(SendPort, port, arguments->NativeArgAt(0));
   GET_NON_NULL_NATIVE_ARGUMENT(Instance, closure, arguments->NativeArgAt(1));
   GET_NON_NULL_NATIVE_ARGUMENT(Instance, message, arguments->NativeArgAt(2));
   GET_NON_NULL_NATIVE_ARGUMENT(Bool, paused, arguments->NativeArgAt(3));
   GET_NATIVE_ARGUMENT(Bool, fatalErrors, arguments->NativeArgAt(4));
   GET_NATIVE_ARGUMENT(SendPort, onExit, arguments->NativeArgAt(5));
   GET_NATIVE_ARGUMENT(SendPort, onError, arguments->NativeArgAt(6));
 
   if (closure.IsClosure()) {
     Function& func = Function::Handle();
     func = Closure::function(closure);
     if (func.IsImplicitClosureFunction() && func.is_static()) {
 #if defined(DEBUG)
       Context& ctx = Context::Handle();
       ctx = Closure::context(closure);
       ASSERT(ctx.num_variables() == 0);
 #endif
       // Get the parent function so that we get the right function name.
       func = func.parent_function();
 
       bool fatal_errors = fatalErrors.IsNull() ? true : fatalErrors.value();
       Dart_Port on_exit_port = onExit.IsNull() ? ILLEGAL_PORT : onExit.Id();
       Dart_Port on_error_port = onError.IsNull() ? ILLEGAL_PORT : onError.Id();
 
-      Spawn(isolate, new IsolateSpawnState(port.Id(),
-                                           func,
-                                           message,
-                                           paused.value(),
-                                           fatal_errors,
-                                           on_exit_port,
-                                           on_error_port));
+      Dart::thread_pool()->Run(new SpawnIsolateTask(
+          new IsolateSpawnState(port.Id(),
+                                isolate->origin_id(),
+                                isolate->init_callback_data(),
+                                func,
+                                message,
+                                paused.value(),
+                                fatal_errors,
+                                on_exit_port,
+                                on_error_port)));
       return Object::null();
     }
   }
   const String& msg = String::Handle(String::New(
       "Isolate.spawn expects to be passed a static or top-level function"));
   Exceptions::ThrowArgumentError(msg);
   return Object::null();
 }
 
 
@@ skipping 94 matching lines @@
     // NULL terminated array.
     utf8_package_map[len] = NULL;
   }
 
   bool fatal_errors = fatalErrors.IsNull() ? true : fatalErrors.value();
   Dart_Port on_exit_port = onExit.IsNull() ? ILLEGAL_PORT : onExit.Id();
   Dart_Port on_error_port = onError.IsNull() ? ILLEGAL_PORT : onError.Id();
 
   IsolateSpawnState* state = new IsolateSpawnState(
       port.Id(),
+      isolate->init_callback_data(),
       canonical_uri,
       utf8_package_root,
       const_cast<const char**>(utf8_package_map),
       args,
       message,
       paused.value(),
       fatal_errors,
       on_exit_port,
       on_error_port);
   // If we were passed a value then override the default flags state for
   // checked mode.
   if (!checked.IsNull()) {
     state->isolate_flags()->set_checked(checked.value());
   }
 
-  Spawn(isolate, state);
+  Dart::thread_pool()->Run(new SpawnIsolateTask(state));
   return Object::null();
 }
 
 
 DEFINE_NATIVE_ENTRY(Isolate_getPortAndCapabilitiesOfCurrentIsolate, 0) {
   const Array& result = Array::Handle(Array::New(3));
   result.SetAt(0, SendPort::Handle(SendPort::New(isolate->main_port())));
   result.SetAt(1, Capability::Handle(
                       Capability::New(isolate->pause_capability())));
   result.SetAt(2, Capability::Handle(
@@ skipping 13 matching lines @@
   MessageWriter writer(&data, &allocator, false);
   writer.WriteMessage(msg);
 
   PortMap::PostMessage(new Message(port.Id(),
                                    data, writer.BytesWritten(),
                                    Message::kOOBPriority));
   return Object::null();
 }
 
 }  // namespace dart