Very simple version of Isolates.

runtime/vm/dart_api_impl_test.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/builtin.h"
 #include "include/dart_api.h"
 #include "include/dart_mirrors_api.h"
 #include "include/dart_native_api.h"
 #include "platform/assert.h"
 #include "platform/json.h"
@@ skipping 3654 matching lines @@
   EXPECT(Dart_IsError(result));
   result = Dart_SetNativeInstanceField(retobj, kNativeFld0, 400);
   EXPECT(Dart_IsError(result));
 }
 
 
 TEST_CASE(NegativeNativeFieldInIsolateMessage) {
   const char* kScriptChars =
       "import 'dart:isolate';\n"
       "import 'dart:nativewrappers';\n"
-      "echo() {\n"
-      "  port.receive((msg, reply) {\n"
-      "    reply.send('echoing ${msg(1)}}');\n"
-      "  });\n"
+      "echo(msg) {\n"
+      "  var data = msg[0];\n"
+      "  var reply = msg[1];\n"
+      "  reply.send('echoing ${data(1)}}');\n"
       "}\n"
       "class Test extends NativeFieldWrapperClass2 {\n"
       "  Test(this.i, this.j);\n"
       "  int i, j;\n"
       "}\n"
       "main() {\n"
-      "  var snd = spawnFunction(echo);\n"
+      "  var port = new RawReceivePort();\n"
       "  var obj = new Test(1,2);\n"
-      "  snd.send(obj, port.toSendPort());\n"
-      "  port.receive((msg, reply) {\n"
+      "  var msg = [obj, port.sendPort];\n"
+      "  var snd = Isolate.spawn(echo, msg);\n"
+      "  port.handler = (msg) {\n"
+      "    port.close();\n"
       "    print('from worker ${msg}');\n"
-      "  });\n"
+      "  };\n"
       "}\n";
 
   DARTSCOPE(Isolate::Current());
 
   // Create a test library and Load up a test script in it.
   Dart_Handle lib = TestCase::LoadTestScript(kScriptChars, NULL);
 
   // Invoke 'main' which should spawn an isolate and try to send an
   // object with native fields over to the spawned isolate. This
   // should result in an unhandled exception which is checked.
@@ skipping 2072 matching lines @@
   EXPECT_EQ(ILLEGAL_PORT, error_port);
 
   // Create the port w/o a current isolate, just to make sure that works.
   Dart_Port port_id1 =
       Dart_NewNativePort("Port123", NewNativePort_send123, true);
 
   TestIsolateScope __test_isolate__;
   const char* kScriptChars =
       "import 'dart:isolate';\n"
       "void callPort(SendPort port) {\n"
-      "  var receivePort = new ReceivePort();\n"
-      "  port.send(null, receivePort.toSendPort());\n"
-      "  receivePort.receive((message, _) {\n"
+      "  var receivePort = new RawReceivePort();\n"
+      "  port.send(null, receivePort.sendPort);\n"
+      "  receivePort.handler = (message) {\n"
       "    receivePort.close();\n"
       "    throw new Exception(message);\n"
-      "  });\n"
+      "  };\n"
       "}\n";
   Dart_Handle lib = TestCase::LoadTestScript(kScriptChars, NULL);
   Dart_EnterScope();
 
   // Create a port w/ a current isolate, to make sure that works too.
   Dart_Port port_id2 =
       Dart_NewNativePort("Port321", NewNativePort_send321, true);
 
   Dart_Handle send_port1 = Dart_NewSendPort(port_id1);
   EXPECT_VALID(send_port1);
@@ skipping 28 matching lines @@
 }
 
 
 static Dart_Isolate RunLoopTestCallback(const char* script_name,
                                         const char* main,
                                         void* data,
                                         char** error) {
   const char* kScriptChars =
       "import 'builtin';\n"
       "import 'dart:isolate';\n"
-      "void entry() {\n"
-      "  port.receive((message, replyTo) {\n"
-      "    if (message) {\n"
-      "      throw new Exception('MakeChildExit');\n"
-      "    } else {\n"
-      "      replyTo.call('hello');\n"
-      "      port.close();\n"
-      "    }\n"
-      "  });\n"
+      "void entry(message) {\n"
+      "  var data = message[0];\n"
+      "  var replyTo = message[1];\n"
+      "  if (data) {\n"
+      "    throw new Exception('MakeChildExit');\n"
+      "  } else {\n"
+      "    replyTo.send('hello');\n"
+      "  }\n"
       "}\n"
       "\n"
       "void main(exc_child, exc_parent) {\n"
-      "  var port = spawnFunction(entry);\n"
-      "  var receivePort = new ReceivePort();\n"
-      "  port.send(exc_child, receivePort.toSendPort());\n"
-      "  receivePort.receive((message, _) {\n"
+      "  var receivePort = new RawReceivePort();\n"
+      "  Isolate.spawn(entry, [exc_child, receivePort.sendPort]);\n"
+      "  receivePort.handler = (message) {\n"
       "    receivePort.close();\n"
       "    if (message != 'hello') throw new Exception('ShouldNotHappen');\n"
       "    if (exc_parent) throw new Exception('MakeParentExit');\n"
-      "  });\n"
+      "  };\n"
       "}\n";
 
   if (Dart_CurrentIsolate() != NULL) {
     Dart_ExitIsolate();
   }
   Dart_Isolate isolate = TestCase::CreateTestIsolate();
   ASSERT(isolate != NULL);
   Dart_EnterScope();
   Dart_Handle url = NewString(TestCase::url());
   Dart_Handle source = NewString(kScriptChars);
@@ skipping 1493 matching lines @@
                                    NewString("main"),
                                    0,
                                    NULL);
   int64_t value = 0;
   result = Dart_IntegerToInt64(result, &value);
   EXPECT_VALID(result);
   EXPECT_EQ(8, value);
 }
 
 }  // namespace dart