Very simple version of Isolates.

runtime/vm/custom_isolate_test.cc

 // Copyright (c) 2011, 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_api.h"
 #include "include/dart_native_api.h"
 
 #include "vm/unit_test.h"
 
 // Custom Isolate Test.
 //
 // This mid-size test uses the Dart Embedding Api to create a custom
 // isolate abstraction.  Instead of having a dedicated thread for each
 // isolate, as is the case normally, this implementation shares a
 // single thread among the isolates using an event queue.
 
 namespace dart {
 
 static void native_echo(Dart_NativeArguments args);
 static void CustomIsolateImpl_start(Dart_NativeArguments args);
 static Dart_NativeFunction NativeLookup(Dart_Handle name, int argc);
 
 
 static const char* kCustomIsolateScriptChars =
     "import 'dart:isolate';\n"
     "\n"
-    "ReceivePort mainPort;\n"
+    "RawReceivePort mainPort;\n"
     "\n"
     "echo(arg) native \"native_echo\";\n"
     "\n"
     "class CustomIsolateImpl implements CustomIsolate {\n"
     "  CustomIsolateImpl(String entry) : _entry = entry{\n"
     "    echo('Constructing isolate');\n"
     "  }\n"
     "\n"
     "  SendPort spawn() {\n"
     "    return _start(_entry);\n"
     "  }\n"
     "\n"
     "  static SendPort _start(entry)\n"
     "      native \"CustomIsolateImpl_start\";\n"
     "\n"
     "  String _entry;\n"
     "}\n"
     "\n"
     "abstract class CustomIsolate {\n"
     "  factory CustomIsolate(String entry) = CustomIsolateImpl;\n"
     "\n"
     "  SendPort spawn();\n"
     "}\n"
     "\n"
     "isolateMain() {\n"
     "   echo('Running isolateMain');\n"
-    "   mainPort.receive((message, SendPort replyTo) {\n"
-    "     echo('Received: $message');\n"
-    "     replyTo.send((message + 1), null);\n"
-    "   });\n"
+    "   mainPort.handler = (message) {\n"
+    "     var data = message[0];\n"
+    "     var replyTo = message[1];\n"
+    "     echo('Received: $data');\n"
+    "     replyTo.send(data + 1);\n"
+    "   };\n"
     "}\n"
     "\n"
     "main() {\n"
     "  var isolate = new CustomIsolate(\"isolateMain\");\n"
-    "  var receivePort = new ReceivePort();\n"
+    "  var receivePort = new RawReceivePort();\n"
     "  SendPort port = isolate.spawn();\n"
-    "  port.send(42, receivePort.toSendPort());\n"
-    "  receivePort.receive((message, _) {\n"
+    "  port.send([42, receivePort.sendPort]);\n"
+    "  receivePort.handler = (message) {\n"
     "    receivePort.close();\n"
     "    echo('Received: $message');\n"
-    "  });\n"
+    "  };\n"
     "  return 'success';\n"
     "}\n";
 
 
 // An entry in our event queue.
 class Event {
  protected:
   explicit Event(Dart_Isolate isolate) : isolate_(isolate), next_(NULL) {}
 
  public:
@@ skipping 252 matching lines @@
     event = event_queue->Get();
   }
   OS::Print("-- Finished event loop --\n");
   EXPECT_STREQ("Received: 43", saved_echo);
   free(const_cast<char*>(saved_echo));
 
   delete event_queue;
 }
 
 }  // namespace dart